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 ofOutgoingStream
on the receiving side.OutgoingStream Some subset of data to be streamed.PreviewKind 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 StreamConnectionFactory StreamEvent StreamEventHandler 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 StreamManager.StreamRateLimiter -
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.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 ofOutgoingStream
on 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 StreamConnectionFactory StreamCoordinator StreamCoordinator
is a helper class that abstracts away maintaining multiple StreamSession and ProgressInfo instances per peer.StreamEvent StreamEvent.Type StreamEventHandler StreamHook StreamManager StreamManager manages currently runningStreamResultFuture
s and provides status of all operation invoked.StreamManager.StreamRateLimiter StreamManagerMBean StreamOperation StreamPlan StreamPlan
is 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.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 StreamConnectionFactory StreamingMessageSender 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 ofOutgoingStream
on the receiving side.OutgoingStream Some subset of data to be streamed.PreviewKind 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 DefaultConnectionFactory StreamConnectionFactory 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.