Package org.apache.cassandra.tools

Class BulkLoadConnectionFactory

java.lang.Object

org.apache.cassandra.streaming.async.NettyStreamingConnectionFactory

org.apache.cassandra.tools.BulkLoadConnectionFactory

All Implemented Interfaces:

StreamingChannel.Factory

public class BulkLoadConnectionFactory
extends NettyStreamingConnectionFactory

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.streaming.StreamingChannel.Factory

StreamingChannel.Factory.Global

Field Summary

Fields inherited from class org.apache.cassandra.streaming.async.NettyStreamingConnectionFactory

MAX_CONNECT_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
BulkLoadConnectionFactory(EncryptionOptions.ServerEncryptionOptions encryptionOptions, int storagePort)

Method Summary

Modifier and Type	Method	Description
NettyStreamingChannel	create(InetSocketAddress to, int messagingVersion, StreamingChannel.Kind kind)
StreamingChannel	create(InetSocketAddress to, InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)
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.

Methods inherited from class org.apache.cassandra.streaming.async.NettyStreamingConnectionFactory

connect

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BulkLoadConnectionFactory

public BulkLoadConnectionFactory(EncryptionOptions.ServerEncryptionOptions encryptionOptions,
 int storagePort)

Method Details

create

public NettyStreamingChannel create(InetSocketAddress to,
 int messagingVersion,
 StreamingChannel.Kind kind)
                             throws IOException

Specified by:

create in interface StreamingChannel.Factory

Overrides:

create in class NettyStreamingConnectionFactory

Throws:

IOException

create

public StreamingChannel create(InetSocketAddress to,
 InetSocketAddress preferred,
 int messagingVersion,
 StreamingChannel.Kind kind)
                        throws IOException

Specified by:

create in interface StreamingChannel.Factory

Overrides:

create in class NettyStreamingConnectionFactory

Throws:

IOException

supportsPreferredIp

public boolean supportsPreferredIp()

Description copied from interface: StreamingChannel.Factory

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