Uses of Class
org.apache.cassandra.streaming.StreamSession
-
Packages that use StreamSession Package Description org.apache.cassandra.db.streaming File transferorg.apache.cassandra.streaming org.apache.cassandra.streaming.async Non-blocking streaming with nettyorg.apache.cassandra.streaming.messages -
-
Uses of StreamSession in org.apache.cassandra.db.streaming
Fields in org.apache.cassandra.db.streaming declared as StreamSession Modifier and Type Field Description protected StreamSession
CassandraStreamReader. session
protected StreamSession
CassandraStreamWriter. session
Methods in org.apache.cassandra.db.streaming that return StreamSession Modifier and Type Method Description StreamSession
CassandraIncomingFile. session()
Methods in org.apache.cassandra.db.streaming with parameters of type StreamSession Modifier and Type Method Description java.util.Collection<OutgoingStream>
CassandraStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, java.util.UUID pendingRepair, PreviewKind previewKind)
StreamReceiver
CassandraStreamManager. createStreamReceiver(StreamSession session, int totalStreams)
IncomingStream
CassandraStreamManager. prepareIncomingStream(StreamSession session, StreamMessageHeader header)
void
CassandraOutgoingFile. write(StreamSession session, DataOutputStreamPlus out, int version)
Constructors in org.apache.cassandra.db.streaming with parameters of type StreamSession Constructor Description CassandraCompressedStreamReader(StreamMessageHeader header, CassandraStreamHeader streamHeader, StreamSession session)
CassandraCompressedStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)
CassandraEntireSSTableStreamReader(StreamMessageHeader messageHeader, CassandraStreamHeader streamHeader, StreamSession session)
CassandraEntireSSTableStreamWriter(SSTableReader sstable, StreamSession session, ComponentContext context)
CassandraIncomingFile(ColumnFamilyStore cfs, StreamSession session, StreamMessageHeader header)
CassandraStreamReader(StreamMessageHeader header, CassandraStreamHeader streamHeader, StreamSession session)
CassandraStreamReceiver(ColumnFamilyStore cfs, StreamSession session, int totalFiles)
CassandraStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)
-
Uses of StreamSession in org.apache.cassandra.streaming
Fields in org.apache.cassandra.streaming declared as StreamSession Modifier and Type Field Description StreamSession
StreamReceiveException. session
protected StreamSession
StreamTask. session
StreamSession that this task belongsMethods in org.apache.cassandra.streaming that return StreamSession Modifier and Type Method Description StreamSession
StreamManager. findSession(InetAddressAndPort peer, java.util.UUID planId, int sessionIndex, boolean searchInitiatorSessions)
StreamSession
StreamCoordinator. getOrCreateNextSession(InetAddressAndPort peer)
StreamSession
StreamCoordinator. getOrCreateSessionById(InetAddressAndPort peer, int id)
StreamSession
StreamResultFuture. getSession(InetAddressAndPort peer, int sessionIndex)
StreamSession
StreamCoordinator. getSessionById(InetAddressAndPort peer, int id)
StreamSession
IncomingStream. session()
Methods in org.apache.cassandra.streaming that return types with arguments of type StreamSession Modifier and Type Method Description java.util.Collection<StreamSession>
StreamCoordinator. getAllStreamSessions()
Methods in org.apache.cassandra.streaming with parameters of type StreamSession Modifier and Type Method Description java.util.Collection<OutgoingStream>
TableStreamManager. createOutgoingStreams(StreamSession session, RangesAtEndpoint replicas, java.util.UUID pendingRepair, PreviewKind previewKind)
Returns a collection ofOutgoingStream
s that contains the data selected by the given replicas, pendingRepair, and preview.StreamReceiver
TableStreamManager. createStreamReceiver(StreamSession session, int totalStreams)
Creates aStreamReceiver
for the given session, expecting the given number of streamsIncomingStream
TableStreamManager. prepareIncomingStream(StreamSession session, StreamMessageHeader header)
Creates anIncomingStream
for the given headervoid
StreamHook. reportIncomingStream(TableId tableId, IncomingStream stream, StreamSession session, int sequenceNumber)
OutgoingStreamMessage
StreamHook. reportOutgoingStream(StreamSession session, OutgoingStream stream, OutgoingStreamMessage message)
void
StreamHook. reportStreamFuture(StreamSession session, StreamResultFuture future)
void
OutgoingStream. write(StreamSession session, DataOutputStreamPlus output, int version)
Write the streams data into the socketConstructors in org.apache.cassandra.streaming with parameters of type StreamSession Constructor Description SessionCompleteEvent(StreamSession session)
StreamReceiveException(StreamSession session, java.lang.String msg)
StreamReceiveException(StreamSession session, java.lang.Throwable t)
StreamReceiveTask(StreamSession session, TableId tableId, int totalStreams, long totalSize)
StreamTask(StreamSession session, TableId tableId)
StreamTransferTask(StreamSession session, TableId tableId)
-
Uses of StreamSession in org.apache.cassandra.streaming.async
Constructors in org.apache.cassandra.streaming.async with parameters of type StreamSession Constructor Description NettyStreamingMessageSender(StreamSession session, OutboundConnectionSettings template, StreamConnectionFactory factory, int streamingVersion, boolean isPreview)
StreamingInboundHandler(InetAddressAndPort remoteAddress, int protocolVersion, StreamSession session)
-
Uses of StreamSession in org.apache.cassandra.streaming.messages
Methods in org.apache.cassandra.streaming.messages that return StreamSession Modifier and Type Method Description StreamSession
IncomingStreamMessage. getOrCreateSession(io.netty.channel.Channel channel)
StreamSession
StreamInitMessage. getOrCreateSession(io.netty.channel.Channel channel)
StreamSession
StreamMessage. getOrCreateSession(io.netty.channel.Channel channel)
Get or create aStreamSession
based on this stream message data: not all stream messages support this, so the default implementation just throws an exception.Methods in org.apache.cassandra.streaming.messages with parameters of type StreamSession Modifier and Type Method Description void
StreamMessageHeader. addSessionInfo(StreamSession session)
void
OutgoingStreamMessage. serialize(DataOutputStreamPlus out, int version, StreamSession session)
static void
StreamMessage. serialize(StreamMessage message, DataOutputStreamPlus out, int version, StreamSession session)
void
StreamMessage.Serializer. serialize(V message, DataOutputStreamPlus out, int version, StreamSession session)
Constructors in org.apache.cassandra.streaming.messages with parameters of type StreamSession Constructor Description OutgoingStreamMessage(TableId tableId, StreamSession session, OutgoingStream stream, int sequenceNumber)
-