Uses of Interface
org.apache.cassandra.streaming.IncomingStream
-
Packages that use IncomingStream Package Description org.apache.cassandra.db.streaming File transferorg.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 anIncomingStream
for the given headerMethods 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 IncomingStream
IncomingStreamMessage. stream
Constructors in org.apache.cassandra.streaming.messages with parameters of type IncomingStream Constructor Description IncomingStreamMessage(IncomingStream stream, StreamMessageHeader header)
-