Uses of Class
org.apache.cassandra.streaming.StreamSession

Packages that use StreamSession

Package	Description
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.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, TimeUUID pendingRepair, PreviewKind previewKind)
StreamReceiver	CassandraStreamManager.createStreamReceiver(StreamSession session, int totalStreams)
protected CassandraStreamReader.StreamDeserializer	CassandraStreamReader.getDeserializer(TableMetadata metadata, TrackedDataInputPlus in, Version inputVersion, StreamSession session, SSTableMultiWriter writer)
IncomingStream	CassandraStreamManager.prepareIncomingStream(StreamSession session, StreamMessageHeader header)
void	CassandraOutgoingFile.write(StreamSession session, StreamingDataOutputPlus 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)
StreamDeserializer(TableMetadata metadata, DataInputPlus in, Version version, SerializationHeader header, StreamSession session, SSTableMultiWriter writer)

Uses of StreamSession in org.apache.cassandra.streaming

Fields in org.apache.cassandra.streaming declared as StreamSession

Modifier and Type	Field	Description
protected StreamSession	StreamDeserializingTask.session
StreamSession	StreamReceiveException.session
protected StreamSession	StreamTask.session	StreamSession that this task belongs

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

Modifier and Type	Method	Description
StreamSession	StreamDeserializingTask.deriveSession(StreamMessage message)
StreamSession	StreamManager.findSession(InetAddressAndPort peer, TimeUUID planId, int sessionIndex, boolean searchInitiatorSessions)
StreamSession	StreamCoordinator.getOrCreateInboundSession(InetAddressAndPort from, StreamingChannel channel, int messagingVersion, int id)
StreamSession	StreamCoordinator.getOrCreateOutboundSession(InetAddressAndPort peer)
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
static java.lang.String	StreamSession.createLogTag(StreamSession session)
static java.lang.String	StreamSession.createLogTag(StreamSession session, io.netty.channel.Channel channel)
static java.lang.String	StreamSession.createLogTag(StreamSession session, java.lang.Object channelId)
static java.lang.String	StreamSession.createLogTag(StreamSession session, StreamingChannel channel)
java.util.Collection<OutgoingStream>	TableStreamManager.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	TableStreamManager.createStreamReceiver(StreamSession session, int totalStreams)	Creates a StreamReceiver for the given session, expecting the given number of streams
IncomingStream	TableStreamManager.prepareIncomingStream(StreamSession session, StreamMessageHeader header)	Creates an IncomingStream for the given header
void	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, StreamingDataOutputPlus output, int version)	Write the streams data into the socket

Constructors in org.apache.cassandra.streaming with parameters of type StreamSession

Constructor	Description
SessionCompleteEvent(StreamSession session)
StreamDeserializingTask(StreamSession session, StreamingChannel channel, int messagingVersion)
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
StreamingMultiplexedChannel(StreamSession session, StreamingChannel.Factory factory, InetAddressAndPort to, StreamingChannel controlChannel, int messagingVersion)

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.getOrCreateAndAttachInboundSession(StreamingChannel channel, int messagingVersion)
StreamSession	StreamInitMessage.getOrCreateAndAttachInboundSession(StreamingChannel channel, int messagingVersion)
StreamSession	StreamMessage.getOrCreateAndAttachInboundSession(StreamingChannel channel, int messagingVersion)	Get or create a StreamSession 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(StreamingDataOutputPlus out, int version, StreamSession session)
static void	StreamMessage.serialize(StreamMessage message, StreamingDataOutputPlus out, int version, StreamSession session)
void	StreamMessage.Serializer.serialize(V message, StreamingDataOutputPlus 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)