Uses of Class
org.apache.cassandra.streaming.StreamResultFuture
Packages that use StreamResultFuture
Package
Description
-
Uses of StreamResultFuture in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht that return StreamResultFuture -
Uses of StreamResultFuture in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return StreamResultFutureModifier and TypeMethodDescriptionSSTableLoader.stream()SSTableLoader.stream(Set<InetAddressAndPort> toIgnore, StreamEventHandler... listeners) -
Uses of StreamResultFuture in org.apache.cassandra.repair
Methods in org.apache.cassandra.repair that return StreamResultFuture -
Uses of StreamResultFuture in org.apache.cassandra.streaming
Methods in org.apache.cassandra.streaming that return StreamResultFutureModifier and TypeMethodDescriptionstatic 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, Collection<StreamEventHandler> listeners, StreamCoordinator coordinator) StreamPlan.execute()Execute thisStreamPlanasynchronously.StreamingState.future()StreamManager.getInitiatorStream(TimeUUID planId) StreamManager.getReceivingStream(TimeUUID planId) StreamManager.registerFollower(StreamResultFuture result) Methods in org.apache.cassandra.streaming with parameters of type StreamResultFutureModifier and TypeMethodDescriptionvoidStreamCoordinator.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) StreamManager.registerFollower(StreamResultFuture result) voidStreamManager.registerInitiator(StreamResultFuture result) voidStreamHook.reportStreamFuture(StreamSession session, StreamResultFuture future) Constructors in org.apache.cassandra.streaming with parameters of type StreamResultFuture