Package org.apache.cassandra.db.streaming

Class CassandraStreamManager

java.lang.Object

org.apache.cassandra.db.streaming.CassandraStreamManager

All Implemented Interfaces:

TableStreamManager

public class CassandraStreamManager
extends Object
implements TableStreamManager

Implements the streaming interface for the native cassandra storage engine. Handles the streaming a one or more section of one of more sstables to and from a specific remote node. The sending side performs a block-level transfer of the source stream, while the receiver must deserilaize that data stream into an partitions and rows, and then write that out as an sstable.

Constructor Summary

Constructors

Constructor	Description
CassandraStreamManager(ColumnFamilyStore cfs)

Method Summary

Modifier and Type	Method	Description
Collection<OutgoingStream>	createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, TimeUUID pendingRepair, PreviewKind previewKind)	Returns a collection of OutgoingStreams that contains the data selected by the given replicas, pendingRepair, and preview.
StreamReceiver	createStreamReceiver(StreamSession session, int totalStreams)	Creates a StreamReceiver for the given session, expecting the given number of streams
IncomingStream	prepareIncomingStream(StreamSession session, StreamMessageHeader header)	Creates an IncomingStream for the given header

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CassandraStreamManager

public CassandraStreamManager(ColumnFamilyStore cfs)

Method Details

prepareIncomingStream

public IncomingStream prepareIncomingStream(StreamSession session,
 StreamMessageHeader header)

Description copied from interface: TableStreamManager

Creates an IncomingStream for the given header

Specified by:

prepareIncomingStream in interface TableStreamManager

createStreamReceiver

public StreamReceiver createStreamReceiver(StreamSession session,
 int totalStreams)

Description copied from interface: TableStreamManager

Creates a StreamReceiver for the given session, expecting the given number of streams

Specified by:

createStreamReceiver in interface TableStreamManager

createOutgoingStreams

public Collection<OutgoingStream> createOutgoingStreams(StreamSession session,
 RangesAtEndpoint replicas,
 TimeUUID pendingRepair,
 PreviewKind previewKind)

Description copied from interface: TableStreamManager

Returns a collection of OutgoingStreams that contains the data selected by the given replicas, pendingRepair, and preview. There aren't any requirements on how data is divided between the outgoing streams

Specified by:

createOutgoingStreams in interface TableStreamManager