Uses of Enum Class
org.apache.cassandra.streaming.StreamOperation
Packages that use StreamOperation
Package
Description
File transfer
-
Uses of StreamOperation in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type StreamOperationModifier and TypeMethodDescriptionstatic voidSystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, String keyspace, Collection<Range<Token>> streamedRanges) -
Uses of StreamOperation in org.apache.cassandra.db.streaming
Constructors in org.apache.cassandra.db.streaming with parameters of type StreamOperationModifierConstructorDescriptionCassandraOutgoingFile(StreamOperation operation, Ref<SSTableReader> ref, List<SSTableReader.PartitionPositionBounds> sections, List<Range<Token>> normalizedRanges, long estimatedKeys) -
Uses of StreamOperation in org.apache.cassandra.dht
Constructors in org.apache.cassandra.dht with parameters of type StreamOperationModifierConstructorDescriptionRangeStreamer(TokenMetadata metadata, Collection<Token> tokens, InetAddressAndPort address, StreamOperation streamOperation, boolean useStrictConsistency, IEndpointSnitch snitch, StreamStateStore stateStore, boolean connectSequentially, int connectionsPerHost) -
Uses of StreamOperation in org.apache.cassandra.streaming
Fields in org.apache.cassandra.streaming declared as StreamOperationModifier and TypeFieldDescriptionfinal StreamOperationStreamEvent.SessionCompleteEvent.streamOperationfinal StreamOperationStreamResultFuture.streamOperationfinal StreamOperationStreamState.streamOperationMethods in org.apache.cassandra.streaming that return StreamOperationModifier and TypeMethodDescriptionstatic StreamOperationStreamOperation.fromString(String text) StreamSession.getStreamOperation()StreamingState.operation()StreamPlan.streamOperation()StreamSession.streamOperation()static StreamOperationReturns the enum constant of this class with the specified name.static StreamOperation[]StreamOperation.values()Returns an array containing the constants of this enum class, in the order they are declared.Methods in org.apache.cassandra.streaming with parameters of type StreamOperationModifier 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) Constructors in org.apache.cassandra.streaming with parameters of type StreamOperationModifierConstructorDescriptionStreamCoordinator(StreamOperation streamOperation, int connectionsPerHost, StreamingChannel.Factory factory, boolean follower, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind) StreamPlan(StreamOperation streamOperation) Start building stream plan.StreamPlan(StreamOperation streamOperation, boolean connectSequentially) StreamPlan(StreamOperation streamOperation, int connectionsPerHost, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind) StreamResultFuture(TimeUUID planId, StreamOperation streamOperation, StreamCoordinator coordinator) Create new StreamResult of givenplanIdand streamOperation.StreamResultFuture(TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind) StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamingChannel.Factory factory, StreamingChannel controlChannel, int messagingVersion, boolean isFollower, int index, TimeUUID pendingRepair, PreviewKind previewKind) Create new streaming session with the peer.StreamState(TimeUUID planId, StreamOperation streamOperation, Set<SessionInfo> sessions) -
Uses of StreamOperation in org.apache.cassandra.streaming.messages
Fields in org.apache.cassandra.streaming.messages declared as StreamOperationConstructors in org.apache.cassandra.streaming.messages with parameters of type StreamOperationModifierConstructorDescriptionStreamInitMessage(InetAddressAndPort from, int sessionIndex, TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind)