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,
java.net.Socket socket,
boolean isForOutgoing,
int version) |
Modifier and Type | Method and Description |
---|---|
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) |
Copyright © 2014 The Apache Software Foundation