Uses of Class
org.apache.cassandra.streaming.StreamOperation
-
Packages that use StreamOperation Package Description org.apache.cassandra.db org.apache.cassandra.db.streaming File transferorg.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
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, 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)
Constructors in org.apache.cassandra.streaming with parameters of type StreamOperation Constructor Description StreamCoordinator(StreamOperation streamOperation, int connectionsPerHost, StreamConnectionFactory factory, boolean follower, boolean connectSequentially, java.util.UUID pendingRepair, PreviewKind previewKind)
StreamPlan(StreamOperation streamOperation)
Start building stream plan.StreamPlan(StreamOperation streamOperation, boolean connectSequentially)
StreamPlan(StreamOperation streamOperation, int connectionsPerHost, boolean connectSequentially, java.util.UUID pendingRepair, PreviewKind previewKind)
StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamConnectionFactory factory, boolean isFollower, int index, java.util.UUID pendingRepair, PreviewKind previewKind)
Create new streaming session with the peer.StreamState(java.util.UUID 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, java.util.UUID planId, StreamOperation streamOperation, java.util.UUID pendingRepair, PreviewKind previewKind)
-