Package | Description |
---|---|
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
StreamPlan |
StreamPlan.connectionFactory(StreamConnectionFactory factory)
Set custom StreamConnectionFactory to be used for establishing connection
|
StreamPlan |
StreamPlan.flushBeforeTransfer(boolean flushBeforeTransfer)
Set flushBeforeTransfer option.
|
StreamPlan |
StreamPlan.listeners(StreamEventHandler handler,
StreamEventHandler... handlers) |
StreamPlan |
StreamPlan.requestRanges(InetAddressAndPort from,
java.lang.String keyspace,
RangesAtEndpoint fullRanges,
RangesAtEndpoint transientRanges)
Request data in
keyspace and ranges from specific node. |
StreamPlan |
StreamPlan.requestRanges(InetAddressAndPort from,
java.lang.String keyspace,
RangesAtEndpoint fullRanges,
RangesAtEndpoint transientRanges,
java.lang.String... columnFamilies)
Request data in
columnFamilies under keyspace and ranges from specific node. |
StreamPlan |
StreamPlan.transferRanges(InetAddressAndPort to,
java.lang.String keyspace,
RangesAtEndpoint replicas,
java.lang.String... columnFamilies)
Add transfer task to send data of specific
columnFamilies under keyspace and ranges . |
StreamPlan |
StreamPlan.transferStreams(InetAddressAndPort to,
java.util.Collection<OutgoingStream> streams)
Add transfer task to send given streams
|
Copyright © 2009-2020 The Apache Software Foundation