Package org.apache.cassandra.streaming
package org.apache.cassandra.streaming
-
ClassDescriptionThe 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.The task that performs the actual deserialization.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 tableThe main streaming hook for a storage implementation.