Package | Description |
---|---|
org.apache.cassandra.io.sstable | |
org.apache.cassandra.streaming | |
org.apache.cassandra.streaming.async |
Non-blocking streaming with netty
|
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(StreamOperation streamOperation,
int connectionsPerHost,
StreamConnectionFactory factory,
boolean follower,
boolean connectSequentially,
java.util.UUID pendingRepair,
PreviewKind previewKind) |
StreamSession(StreamOperation streamOperation,
InetAddressAndPort peer,
StreamConnectionFactory factory,
boolean isFollower,
int index,
java.util.UUID pendingRepair,
PreviewKind previewKind)
Create new streaming session with the peer.
|
Constructor and Description |
---|
NettyStreamingMessageSender(StreamSession session,
OutboundConnectionSettings template,
StreamConnectionFactory factory,
int streamingVersion,
boolean isPreview) |
Modifier and Type | Class and Description |
---|---|
class |
BulkLoadConnectionFactory |
Copyright © 2009-2020 The Apache Software Foundation