Uses of Class
org.apache.cassandra.streaming.StreamResultFuture
-
Packages that use StreamResultFuture Package Description org.apache.cassandra.dht org.apache.cassandra.io.sstable org.apache.cassandra.streaming -
-
Uses of StreamResultFuture in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht that return StreamResultFuture Modifier and Type Method Description StreamResultFuture
RangeStreamer. fetchAsync()
-
Uses of StreamResultFuture in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return StreamResultFuture Modifier and Type Method Description StreamResultFuture
SSTableLoader. stream()
StreamResultFuture
SSTableLoader. stream(java.util.Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners)
-
Uses of StreamResultFuture in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return StreamResultFuture Modifier and Type Method Description static StreamResultFuture
StreamResultFuture. createFollower(int sessionIndex, java.util.UUID planId, StreamOperation streamOperation, InetAddressAndPort from, io.netty.channel.Channel channel, java.util.UUID pendingRepair, PreviewKind previewKind)
static StreamResultFuture
StreamResultFuture. createInitiator(java.util.UUID planId, StreamOperation streamOperation, java.util.Collection<StreamEventHandler> listeners, StreamCoordinator coordinator)
StreamResultFuture
StreamPlan. execute()
Execute thisStreamPlan
asynchronously.StreamResultFuture
StreamManager. getReceivingStream(java.util.UUID planId)
StreamResultFuture
StreamManager. registerFollower(StreamResultFuture result)
Methods in org.apache.cassandra.streaming with parameters of type StreamResultFuture Modifier and Type Method Description void
StreamCoordinator. connect(StreamResultFuture future)
void
StreamSession. init(StreamResultFuture streamResult)
Bind this session to report to specificStreamResultFuture
and perform pre-streaming initialization.StreamResultFuture
StreamManager. registerFollower(StreamResultFuture result)
void
StreamManager. registerInitiator(StreamResultFuture result)
void
StreamHook. reportStreamFuture(StreamSession session, StreamResultFuture future)
-