Uses of Interface
org.apache.cassandra.streaming.IncomingStream

Packages that use IncomingStream

Package	Description
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.streaming
org.apache.cassandra.streaming.messages

Uses of IncomingStream in org.apache.cassandra.db.streaming

Classes in org.apache.cassandra.db.streaming that implement IncomingStream

Modifier and Type	Class	Description
class	CassandraIncomingFile	used to receive the part(or whole) of a SSTable data file.

Methods in org.apache.cassandra.db.streaming that return IncomingStream

Modifier and Type	Method	Description
IncomingStream	CassandraStreamManager.prepareIncomingStream(StreamSession session, StreamMessageHeader header)

Methods in org.apache.cassandra.db.streaming with parameters of type IncomingStream

Modifier and Type	Method	Description
void	CassandraStreamReceiver.discardStream(IncomingStream stream)
void	CassandraStreamReceiver.received(IncomingStream stream)

Uses of IncomingStream in org.apache.cassandra.streaming

Methods in org.apache.cassandra.streaming that return IncomingStream

Modifier and Type	Method	Description
IncomingStream	TableStreamManager.prepareIncomingStream(StreamSession session, StreamMessageHeader header)	Creates an IncomingStream for the given header

Methods in org.apache.cassandra.streaming with parameters of type IncomingStream

Modifier and Type	Method	Description
void	StreamReceiver.discardStream(IncomingStream stream)	This is called when we've received stream data we can't add to the received set for some reason, usually when we've received data for a session which has been closed.
void	StreamReceiver.received(IncomingStream stream)	Called after we've finished receiving stream data.
void	StreamReceiveTask.received(IncomingStream stream)	Process received stream.
void	StreamHook.reportIncomingStream(TableId tableId, IncomingStream stream, StreamSession session, int sequenceNumber)

Uses of IncomingStream in org.apache.cassandra.streaming.messages

Fields in org.apache.cassandra.streaming.messages declared as IncomingStream

Modifier and Type	Field	Description
final IncomingStream	IncomingStreamMessage.stream

Constructors in org.apache.cassandra.streaming.messages with parameters of type IncomingStream

Modifier	Constructor	Description
	IncomingStreamMessage(IncomingStream stream, StreamMessageHeader header)