Uses of Class
org.apache.cassandra.streaming.StreamOperation

Packages that use StreamOperation

Package	Description
org.apache.cassandra.db
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.dht
org.apache.cassandra.streaming
org.apache.cassandra.streaming.messages

Uses of StreamOperation in org.apache.cassandra.db

Methods in org.apache.cassandra.db with parameters of type StreamOperation

Modifier and Type	Method	Description
static void	SystemKeyspace.updateTransferredRanges(StreamOperation streamOperation, InetAddressAndPort peer, java.lang.String keyspace, java.util.Collection<Range<Token>> streamedRanges)

Uses of StreamOperation in org.apache.cassandra.db.streaming

Constructors in org.apache.cassandra.db.streaming with parameters of type StreamOperation

Constructor	Description
CassandraOutgoingFile(StreamOperation operation, Ref<SSTableReader> ref, java.util.List<SSTableReader.PartitionPositionBounds> sections, java.util.List<Range<Token>> normalizedRanges, long estimatedKeys)

Uses of StreamOperation in org.apache.cassandra.dht

Constructors in org.apache.cassandra.dht with parameters of type StreamOperation

Constructor	Description
RangeStreamer(TokenMetadata metadata, java.util.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 StreamOperation

Modifier and Type	Field	Description
StreamOperation	StreamEvent.SessionCompleteEvent.streamOperation
StreamOperation	StreamResultFuture.streamOperation
StreamOperation	StreamState.streamOperation

Methods in org.apache.cassandra.streaming that return StreamOperation

Modifier and Type	Method	Description
static StreamOperation	StreamOperation.fromString(java.lang.String text)
StreamOperation	StreamSession.getStreamOperation()
StreamOperation	StreamingState.operation()
StreamOperation	StreamSession.streamOperation()
static StreamOperation	StreamOperation.valueOf(java.lang.String name)	Returns the enum constant of this type with the specified name.
static StreamOperation[]	StreamOperation.values()	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.cassandra.streaming with parameters of type StreamOperation

Modifier and Type	Method	Description
static StreamResultFuture	StreamResultFuture.createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)
static StreamResultFuture	StreamResultFuture.createInitiator(TimeUUID planId, StreamOperation streamOperation, java.util.Collection<StreamEventHandler> listeners, StreamCoordinator coordinator)

Constructors in org.apache.cassandra.streaming with parameters of type StreamOperation

Constructor	Description
StreamCoordinator(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 given planId and 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, java.util.Set<SessionInfo> sessions)

Uses of StreamOperation in org.apache.cassandra.streaming.messages

Fields in org.apache.cassandra.streaming.messages declared as StreamOperation

Modifier and Type	Field	Description
StreamOperation	StreamInitMessage.streamOperation

Constructors in org.apache.cassandra.streaming.messages with parameters of type StreamOperation

Constructor	Description
StreamInitMessage(InetAddressAndPort from, int sessionIndex, TimeUUID planId, StreamOperation streamOperation, TimeUUID pendingRepair, PreviewKind previewKind)