Package org.apache.cassandra.streaming

Interface StreamingChannel.Factory

All Known Implementing Classes:

BulkLoadConnectionFactory, NettyStreamingConnectionFactory

Enclosing interface:

StreamingChannel

public static interface StreamingChannel.Factory

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	StreamingChannel.Factory.Global

Method Summary

Modifier and Type	Method	Description
StreamingChannel	create(java.net.InetSocketAddress to, int messagingVersion, StreamingChannel.Kind kind)
default StreamingChannel	create(java.net.InetSocketAddress to, java.net.InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)
default boolean	supportsPreferredIp()	Provide way to disable getPreferredIP() for tools without access to the system keyspace CASSANDRA-17663 moves calls to SystemKeyspace.getPreferredIP() outside of any threads that are regularly interrupted.

Method Detail

create

StreamingChannel create(java.net.InetSocketAddress to,
                        int messagingVersion,
                        StreamingChannel.Kind kind)
                 throws java.io.IOException

Throws:

java.io.IOException

create

default StreamingChannel create(java.net.InetSocketAddress to,
                                java.net.InetSocketAddress preferred,
                                int messagingVersion,
                                StreamingChannel.Kind kind)
                         throws java.io.IOException

Throws:

java.io.IOException

supportsPreferredIp

default boolean supportsPreferredIp()

Provide way to disable getPreferredIP() for tools without access to the system keyspace CASSANDRA-17663 moves calls to SystemKeyspace.getPreferredIP() outside of any threads that are regularly interrupted. However the streaming subsystem is also used by the bulk loader tool, which does not have direct access to the local tables and uses the client metadata/queries to retrieve it.

Returns:

true if SystemKeyspace.getPreferredIP() should be used when connecting