Uses of Class org.apache.cassandra.streaming.StreamSession (apache-cassandra API)

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, 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 belongs

Methods 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 of `OutgoingStream`s 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, DataOutputStreamPlus 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)`
`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 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(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)`