Uses of Package
org.apache.cassandra.streaming
Packages that use org.apache.cassandra.streaming
Package
Description
File transfer
Non-blocking streaming with netty
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.dbClassDescriptionThe main streaming hook for a storage implementation.
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.db.streamingClassDescriptionThe counterpart of
OutgoingStreamon the receiving side.Some subset of data to be streamed.StreamReceiver acts as a staging area for incoming data.Handles the streaming a one or more streams to and from a specific remote node.The main streaming hook for a storage implementation. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.dhtClassDescriptionA future on the result (
StreamState) of a streaming plan.Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.exceptions
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.io.sstableClassDescriptionA future on the result (
StreamState) of a streaming plan.Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.net
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repairClassDescription
StreamPlanis a helper class that builds StreamOperation of given configuration.A future on the result (StreamState) of a streaming plan.Current snapshot of streaming progress. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repair.messages
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.repair.state
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.service
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streamingClassDescriptionThe counterpart of
OutgoingStreamon the receiving side.Some subset of data to be streamed.ProgressInfo contains stream transfer progress.Direction of the stream.Stream session info.StreamCoordinatoris a helper class that abstracts away maintaining multiple StreamSession and ProgressInfo instances per peer.StreamManager manages currently runningStreamResultFutures and provides status of all operation invoked.StreamPlanis a helper class that builds StreamOperation of given configuration.StreamReceiver acts as a staging area for incoming data.Task that manages receiving files for the session for certain ColumnFamily.A future on the result (StreamState) of a streaming plan.Handles the streaming a one or more streams to and from a specific remote node.State Transition:Current snapshot of streaming progress.Summary of streaming.StreamTask is an abstraction of the streaming task performed over specific ColumnFamily.StreamTransferTask sends streams for a given table -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming.asyncClassDescriptionHandles 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.managementClassDescriptionProgressInfo contains stream transfer progress.Stream session info.Current snapshot of streaming progress.Summary of streaming.
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.streaming.messagesClassDescriptionThe counterpart of
OutgoingStreamon the receiving side.Some subset of data to be streamed.Handles the streaming a one or more streams to and from a specific remote node.Summary of streaming. -
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.toolsClassDescriptionCurrent snapshot of streaming progress.
-
Classes in org.apache.cassandra.streaming used by org.apache.cassandra.tools.nodetool