Package org.apache.cassandra.streaming

Interface TableStreamManager

All Known Implementing Classes:

CassandraStreamManager

public interface TableStreamManager

The main streaming hook for a storage implementation. From here, the streaming system can get instances of StreamReceiver, IncomingStream, and OutgoingStream, which expose the interfaces into the the underlying storage implementation needed to make streaming work.

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

Method Details

createStreamReceiver

StreamReceiver createStreamReceiver(StreamSession session,
 int totalStreams)

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

prepareIncomingStream

IncomingStream prepareIncomingStream(StreamSession session,
 StreamMessageHeader header)

Creates an IncomingStream for the given header

createOutgoingStreams

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. There aren't any requirements on how data is divided between the outgoing streams