Package | Description |
---|---|
org.apache.cassandra.dht | |
org.apache.cassandra.io.sstable | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
RangeStreamer.fetchAsync() |
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
SSTableLoader.stream() |
StreamResultFuture |
SSTableLoader.stream(java.util.Set<java.net.InetAddress> toIgnore,
StreamEventHandler... listeners) |
Modifier and Type | Method and Description |
---|---|
StreamResultFuture |
StreamPlan.execute()
Execute this
StreamPlan asynchronously. |
StreamResultFuture |
StreamManager.getReceivingStream(java.util.UUID planId) |
static StreamResultFuture |
StreamResultFuture.initReceivingSide(int sessionIndex,
java.util.UUID planId,
java.lang.String description,
java.net.InetAddress from,
IncomingStreamingConnection connection,
boolean isForOutgoing,
int version,
boolean keepSSTableLevel,
boolean isIncremental) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCoordinator.connect(StreamResultFuture future) |
void |
StreamSession.init(StreamResultFuture streamResult)
Bind this session to report to specific
StreamResultFuture and
perform pre-streaming initialization. |
void |
StreamManager.register(StreamResultFuture result) |
void |
StreamManager.registerReceiving(StreamResultFuture result) |
void |
StreamHook.reportStreamFuture(StreamSession session,
StreamResultFuture future) |
Copyright © 2018 The Apache Software Foundation