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 StreamResultFutureRangeStreamer. 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 StreamResultFutureSSTableLoader. stream()StreamResultFutureSSTableLoader. 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 StreamResultFutureStreamResultFuture. createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)static StreamResultFutureStreamResultFuture. createInitiator(TimeUUID planId, StreamOperation streamOperation, java.util.Collection<StreamEventHandler> listeners, StreamCoordinator coordinator)StreamResultFutureStreamPlan. execute()Execute thisStreamPlanasynchronously.StreamResultFutureStreamingState. future()StreamResultFutureStreamManager. getInitiatorStream(TimeUUID planId)StreamResultFutureStreamManager. getReceivingStream(TimeUUID planId)StreamResultFutureStreamManager. registerFollower(StreamResultFuture result)Methods in org.apache.cassandra.streaming with parameters of type StreamResultFuture Modifier and Type Method Description voidStreamCoordinator. connect(StreamResultFuture future)voidStreamSession. init(StreamResultFuture streamResult)Bind this session to report to specificStreamResultFutureand perform pre-streaming initialization.default voidStreamManager.StreamListener. onRegister(StreamResultFuture result)voidStreamManager. putFollowerStream(StreamResultFuture future)voidStreamManager. putInitiatorStream(StreamResultFuture future)StreamResultFutureStreamManager. registerFollower(StreamResultFuture result)voidStreamManager. registerInitiator(StreamResultFuture result)voidStreamHook. reportStreamFuture(StreamSession session, StreamResultFuture future)Constructors in org.apache.cassandra.streaming with parameters of type StreamResultFuture Constructor Description StreamingState(StreamResultFuture result)
-