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 this StreamPlan 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 specific StreamResultFuture and perform pre-streaming initialization.
StreamResultFuture	StreamManager.registerFollower(StreamResultFuture result)
void	StreamManager.registerInitiator(StreamResultFuture result)
void	StreamHook.reportStreamFuture(StreamSession session, StreamResultFuture future)