Uses of Package
org.apache.cassandra.streaming
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.db Class Description StreamOperation TableStreamManager The main streaming hook for a storage implementation. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.db.streaming Class Description IncomingStream The counterpart ofOutgoingStreamon the receiving side.OutgoingStream Some subset of data to be streamed.PreviewKind StreamingDataOutputPlus StreamManager.StreamRateLimiter StreamOperation StreamReceiver StreamReceiver acts as a staging area for incoming data.StreamSession Handles the streaming a one or more streams to and from a specific remote node.TableStreamManager The main streaming hook for a storage implementation. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.dht Class Description StreamEvent StreamEventHandler StreamOperation StreamResultFuture A future on the result (StreamState) of a streaming plan.StreamState Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.exceptions Class Description PreviewKind -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.io.sstable Class Description StreamEvent StreamEventHandler StreamingChannel.Factory StreamResultFuture A future on the result (StreamState) of a streaming plan.StreamState Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.net Class Description StreamingDataInputPlus StreamingDataOutputPlus StreamingDataOutputPlus.RateLimiter StreamingDataOutputPlus.Write -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repair Class Description PreviewKind SessionSummary StreamEvent StreamEventHandler StreamState Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repair.messages Class Description PreviewKind SessionSummary -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repair.state Class Description PreviewKind -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.service Class Description PreviewKind StreamState Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming Class Description IncomingStream The counterpart ofOutgoingStreamon the receiving side.OutgoingStream Some subset of data to be streamed.PreviewKind ProgressInfo ProgressInfo contains stream transfer progress.ProgressInfo.Direction Direction of the stream.ReplicationDoneVerbHandler SessionInfo Stream session info.SessionSummary StreamCoordinator StreamCoordinatoris a helper class that abstracts away maintaining multiple StreamSession and ProgressInfo instances per peer.StreamEvent StreamEvent.Type StreamEventHandler StreamHook StreamingChannel StreamingChannel.Factory StreamingChannel.Kind StreamingChannel.Send StreamingDataInputPlus StreamingDataOutputPlus StreamingDataOutputPlus.BufferSupplier StreamingDataOutputPlus.RateLimiter StreamingDataOutputPlus.Write StreamingState StreamingState.Phase StreamingState.Sessions StreamingState.Status StreamManager StreamManager manages currently runningStreamResultFutures and provides status of all operation invoked.StreamManager.StreamListener StreamManager.StreamRateLimiter StreamManagerMBean StreamOperation StreamPlan StreamPlanis a helper class that builds StreamOperation of given configuration.StreamReceiver StreamReceiver acts as a staging area for incoming data.StreamReceiveTask Task that manages receiving files for the session for certain ColumnFamily.StreamRequest StreamResultFuture A future on the result (StreamState) of a streaming plan.StreamSession Handles the streaming a one or more streams to and from a specific remote node.StreamSession.MessageStateSink StreamSession.PrepareDirection StreamSession.State State Transition:StreamState Current snapshot of streaming progress.StreamSummary Summary of streaming.StreamTask StreamTask is an abstraction of the streaming task performed over specific ColumnFamily.StreamTransferTask StreamTransferTask sends streams for a given table -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming.async Class Description StreamingChannel StreamingChannel.Factory StreamingChannel.Kind StreamingChannel.Send StreamingDataInputPlus StreamingDataOutputPlus StreamingDataOutputPlus.Write StreamSession Handles the streaming a one or more streams to and from a specific remote node. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming.management Class Description ProgressInfo ProgressInfo contains stream transfer progress.SessionInfo Stream session info.StreamEvent StreamEvent.SessionCompleteEvent StreamEventHandler StreamState Current snapshot of streaming progress.StreamSummary Summary of streaming. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming.messages Class Description IncomingStream The counterpart ofOutgoingStreamon the receiving side.OutgoingStream Some subset of data to be streamed.PreviewKind StreamingChannel StreamingDataOutputPlus StreamOperation StreamRequest StreamSession Handles the streaming a one or more streams to and from a specific remote node.StreamSummary Summary of streaming. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.tools Class Description StreamingChannel StreamingChannel.Factory StreamingChannel.Kind StreamManagerMBean StreamState Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.tools.nodetool Class Description SessionInfo Stream session info.