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

Packages that use StreamingChannel

Package	Description
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.streaming.messages
org.apache.cassandra.tools

Uses of StreamingChannel in org.apache.cassandra.streaming

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

Modifier and Type	Method	Description
StreamingChannel	StreamingChannel.Factory.create(InetSocketAddress to, int messagingVersion, StreamingChannel.Kind kind)
default StreamingChannel	StreamingChannel.Factory.create(InetSocketAddress to, InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)

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

Modifier and Type	Method	Description
boolean	StreamSession.attachInbound(StreamingChannel channel)	Attach a channel to this session upon receiving the first inbound message.
boolean	StreamSession.attachOutbound(StreamingChannel channel)	Attach a channel to this session upon sending the first outbound message.
static StreamResultFuture	StreamResultFuture.createFollower(int sessionIndex, TimeUUID planId, StreamOperation streamOperation, InetAddressAndPort from, StreamingChannel channel, int messagingVersion, TimeUUID pendingRepair, PreviewKind previewKind)
static String	StreamSession.createLogTag(StreamSession session, StreamingChannel channel)
StreamSession	StreamCoordinator.getOrCreateInboundSession(InetAddressAndPort from, StreamingChannel channel, int messagingVersion, int id)

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

Modifier	Constructor	Description
	StreamDeserializingTask(StreamSession session, StreamingChannel channel, int messagingVersion)
	StreamSession(StreamOperation streamOperation, InetAddressAndPort peer, StreamingChannel.Factory factory, StreamingChannel controlChannel, int messagingVersion, boolean isFollower, int index, TimeUUID pendingRepair, PreviewKind previewKind)	Create new streaming session with the peer.

Uses of StreamingChannel in org.apache.cassandra.streaming.async

Classes in org.apache.cassandra.streaming.async that implement StreamingChannel

Modifier and Type	Class	Description
class	NettyStreamingChannel

Methods in org.apache.cassandra.streaming.async that return StreamingChannel

Modifier and Type	Method	Description
StreamingChannel	NettyStreamingConnectionFactory.create(InetSocketAddress to, int messagingVersion, StreamingChannel.Kind kind)
StreamingChannel	NettyStreamingConnectionFactory.create(InetSocketAddress to, InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)

Methods in org.apache.cassandra.streaming.async with parameters of type StreamingChannel

Modifier and Type	Method	Description
io.netty.util.concurrent.Future<?>	StreamingMultiplexedChannel.sendMessage(StreamingChannel channel, StreamMessage message)

Constructors in org.apache.cassandra.streaming.async with parameters of type StreamingChannel

Modifier	Constructor	Description
	StreamingMultiplexedChannel(StreamSession session, StreamingChannel.Factory factory, InetAddressAndPort to, StreamingChannel controlChannel, int messagingVersion)

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

Methods in org.apache.cassandra.streaming.messages with parameters of type StreamingChannel

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.

Uses of StreamingChannel in org.apache.cassandra.tools

Methods in org.apache.cassandra.tools that return StreamingChannel

Modifier and Type	Method	Description
StreamingChannel	BulkLoadConnectionFactory.create(InetSocketAddress to, InetSocketAddress preferred, int messagingVersion, StreamingChannel.Kind kind)