Package org.apache.cassandra.streaming

Interface StreamingDataOutputPlus

All Superinterfaces:

AutoCloseable, Closeable, DataOutput, DataOutputPlus

All Known Implementing Classes:

AsyncStreamingOutputPlus, StreamingDataOutputPlusFixed

public interface StreamingDataOutputPlus
extends DataOutputPlus, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	StreamingDataOutputPlus.BufferSupplier
static interface	StreamingDataOutputPlus.RateLimiter
static interface	StreamingDataOutputPlus.Write

Method Summary

Modifier and Type	Method	Description
default void	flush()
long	writeFileToChannel(FileChannel file, StreamingDataOutputPlus.RateLimiter limiter)	Writes all data in file channel to stream: * For zero-copy-streaming, 1MiB at a time, with at most 2MiB in flight at once.
int	writeToChannel(StreamingDataOutputPlus.Write write, StreamingDataOutputPlus.RateLimiter limiter)	Provide a lambda that can request a buffer of suitable size, then fill the buffer and have that buffer written and flushed to the underlying channel, without having to handle buffer allocation, lifetime or cleanup, including in case of exceptions.

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface java.io.DataOutput

write, write, write, writeBoolean, writeByte, writeBytes, writeChar, writeChars, writeDouble, writeFloat, writeInt, writeLong, writeShort, writeUTF

Methods inherited from interface org.apache.cassandra.io.util.DataOutputPlus

bytesLeftInPage, hasPosition, maxBytesInPage, paddedPosition, padToPageBoundary, position, write, write, writeMostSignificantBytes, writeUnsignedVInt, writeUnsignedVInt, writeUnsignedVInt32, writeVInt, writeVInt, writeVInt32

Method Details

writeToChannel

int writeToChannel(StreamingDataOutputPlus.Write write,
 StreamingDataOutputPlus.RateLimiter limiter)
            throws IOException

Provide a lambda that can request a buffer of suitable size, then fill the buffer and have that buffer written and flushed to the underlying channel, without having to handle buffer allocation, lifetime or cleanup, including in case of exceptions.

Any exception thrown by the Write will be propagated to the caller, after any buffer is cleaned up.

Throws:

IOException

writeFileToChannel

long writeFileToChannel(FileChannel file,
 StreamingDataOutputPlus.RateLimiter limiter)
                 throws IOException

Writes all data in file channel to stream:
* For zero-copy-streaming, 1MiB at a time, with at most 2MiB in flight at once.
* For streaming with SSL, 64KiB at a time, with at most 32+64KiB (default low water mark + batch size) in flight.

This method takes ownership of the provided FileChannel.

WARNING: this method blocks only for permission to write to the netty channel; it exits before the FileRegion(zero-copy) or ByteBuffer(ssl) is flushed to the network.

Throws:

IOException

flush

default void flush()
            throws IOException

Throws:

IOException