Package 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 Description BulkLoadConnectionFactory(int secureStoragePort, EncryptionOptions.ServerEncryptionOptions encryptionOptions, boolean outboundBindAny)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description io.netty.channel.Channel
createConnection(OutboundConnectionSettings template, int messagingVersion)
-
-
-
Constructor Detail
-
BulkLoadConnectionFactory
public BulkLoadConnectionFactory(int secureStoragePort, EncryptionOptions.ServerEncryptionOptions encryptionOptions, boolean outboundBindAny)
-
-
Method Detail
-
createConnection
public io.netty.channel.Channel createConnection(OutboundConnectionSettings template, int messagingVersion) throws java.io.IOException
- Specified by:
createConnection
in interfaceStreamConnectionFactory
- Overrides:
createConnection
in classDefaultConnectionFactory
- Throws:
java.io.IOException
-
-