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 voidSystemKeyspace. 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 StreamOperationStreamEvent.SessionCompleteEvent. streamOperationStreamOperationStreamResultFuture. streamOperationStreamOperationStreamState. streamOperationMethods in org.apache.cassandra.streaming that return StreamOperation Modifier and Type Method Description static StreamOperationStreamOperation. fromString(java.lang.String text)StreamOperationStreamSession. getStreamOperation()StreamOperationStreamSession. streamOperation()static StreamOperationStreamOperation. 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 StreamResultFutureStreamResultFuture. createFollower(int sessionIndex, java.util.UUID planId, StreamOperation streamOperation, InetAddressAndPort from, io.netty.channel.Channel channel, java.util.UUID pendingRepair, PreviewKind previewKind)static StreamResultFutureStreamResultFuture. 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 StreamOperationStreamInitMessage. streamOperationConstructors 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)
-