org.apache.cassandra.tools

Class BulkLoadConnectionFactory

java.lang.Object

org.apache.cassandra.streaming.DefaultConnectionFactory

org.apache.cassandra.tools.BulkLoadConnectionFactory

All Implemented Interfaces:

StreamConnectionFactory

public class BulkLoadConnectionFactory
extends DefaultConnectionFactory
implements StreamConnectionFactory

Field Summary

Fields inherited from class org.apache.cassandra.streaming.DefaultConnectionFactory

MAX_CONNECT_ATTEMPTS

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	createConnection(OutboundConnectionSettings template, int messagingVersion)
boolean	supportsPreferredIp() Provide way to disable getPreferredIP() for tools without access to the system keyspace

Methods inherited from class java.lang.Object

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

Constructor Detail

BulkLoadConnectionFactory

public BulkLoadConnectionFactory(EncryptionOptions.ServerEncryptionOptions encryptionOptions,
                                 int storagePort)

Method Detail

createConnection

public io.netty.channel.Channel createConnection(OutboundConnectionSettings template,
                                                 int messagingVersion)
                                          throws java.io.IOException

Specified by:

createConnection in interface StreamConnectionFactory

Overrides:

createConnection in class DefaultConnectionFactory

Throws:

java.io.IOException

supportsPreferredIp

public boolean supportsPreferredIp()

Description copied from interface: StreamConnectionFactory

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.

Specified by:

supportsPreferredIp in interface StreamConnectionFactory

Returns:

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