Package | Description |
---|---|
org.apache.cassandra.io.sstable | |
org.apache.cassandra.streaming | |
org.apache.cassandra.tools |
Modifier and Type | Method and Description |
---|---|
StreamConnectionFactory |
SSTableLoader.Client.getConnectionFactory()
Provides connection factory.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultConnectionFactory |
Modifier and Type | Method and Description |
---|---|
StreamPlan |
StreamPlan.connectionFactory(StreamConnectionFactory factory)
Set custom StreamConnectionFactory to be used for establishing connection
|
void |
StreamCoordinator.setConnectionFactory(StreamConnectionFactory factory) |
Constructor and Description |
---|
StreamCoordinator(int connectionsPerHost,
boolean keepSSTableLevel,
boolean isIncremental,
StreamConnectionFactory factory,
boolean connectSequentially) |
StreamSession(java.net.InetAddress peer,
java.net.InetAddress connecting,
StreamConnectionFactory factory,
int index,
boolean keepSSTableLevel,
boolean isIncremental)
Create new streaming session with the peer.
|
Modifier and Type | Class and Description |
---|---|
class |
BulkLoadConnectionFactory |
Copyright © 2018 The Apache Software Foundation