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

Packages that use StreamingDataOutputPlus

Package	Description
org.apache.cassandra.db.streaming	File transfer
org.apache.cassandra.net
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.streaming.messages

Uses of StreamingDataOutputPlus in org.apache.cassandra.db.streaming

Methods in org.apache.cassandra.db.streaming with parameters of type StreamingDataOutputPlus

Modifier and Type	Method	Description
void	CassandraCompressedStreamWriter.write(StreamingDataOutputPlus out)
void	CassandraEntireSSTableStreamWriter.write(StreamingDataOutputPlus out)	Stream the entire file to given channel.
void	CassandraOutgoingFile.write(StreamSession session, StreamingDataOutputPlus out, int version)
protected long	CassandraStreamWriter.write(ChannelProxy proxy, DataIntegrityMetadata.ChecksumValidator validator, StreamingDataOutputPlus output, long start, int transferOffset, int toTransfer, int bufferSize)	Sequentially read bytes from the file and write them to the output stream
void	CassandraStreamWriter.write(StreamingDataOutputPlus out)	Stream file of specified sections to given channel.

Uses of StreamingDataOutputPlus in org.apache.cassandra.net

Classes in org.apache.cassandra.net that implement StreamingDataOutputPlus

Modifier and Type	Class	Description
class	AsyncStreamingOutputPlus	A DataOutputStreamPlus that writes ASYNCHRONOUSLY to a Netty Channel.

Uses of StreamingDataOutputPlus in org.apache.cassandra.streaming

Classes in org.apache.cassandra.streaming that implement StreamingDataOutputPlus

Modifier and Type	Class	Description
class	StreamingDataOutputPlusFixed

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

Modifier and Type	Method	Description
StreamingDataOutputPlus	StreamingChannel.acquireOut()	until closed, cannot invoke StreamingChannel.send(Send)

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

Modifier and Type	Method	Description
void	OutgoingStream.write(StreamSession session, StreamingDataOutputPlus output, int version)	Write the streams data into the socket

Method parameters in org.apache.cassandra.streaming with type arguments of type StreamingDataOutputPlus

Modifier and Type	Method	Description
void	StreamingChannel.Send.send(IntFunction<StreamingDataOutputPlus> outSupplier)

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

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

Modifier and Type	Method	Description
StreamingDataOutputPlus	NettyStreamingChannel.acquireOut()

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

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

Modifier and Type	Method	Description
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)