Package org.apache.cassandra.io.util

Class WrappedDataOutputStreamPlus

java.lang.Object

java.io.OutputStream

org.apache.cassandra.io.util.DataOutputStreamPlus

org.apache.cassandra.io.util.UnbufferedDataOutputStreamPlus

org.apache.cassandra.io.util.WrappedDataOutputStreamPlus

All Implemented Interfaces:

Closeable, DataOutput, Flushable, AutoCloseable, DataOutputPlus

public class WrappedDataOutputStreamPlus
extends UnbufferedDataOutputStreamPlus

When possible use WrappedDataOutputStreamPlus instead of this class, as it will be more efficient when using Plus methods. This class is only for situations where it cannot be used. The channel provided by this class is just a wrapper around the output stream.

Field Summary

Fields

Modifier and Type	Field	Description
protected final OutputStream	out

Fields inherited from class org.apache.cassandra.io.util.DataOutputStreamPlus

channel

Constructor Summary

Constructors

Constructor	Description
WrappedDataOutputStreamPlus(OutputStream out)
WrappedDataOutputStreamPlus(OutputStream out, WritableByteChannel channel)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
void	write(byte[] buffer, int offset, int count)	Writes count bytes from the byte array buffer starting at offset to this RandomAccessFile starting at the current file pointer..
void	write(int oneByte)	Writes the specified byte oneByte to this RandomAccessFile starting at the current file pointer.

Methods inherited from class org.apache.cassandra.io.util.UnbufferedDataOutputStreamPlus

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

Methods inherited from class org.apache.cassandra.io.util.DataOutputStreamPlus

newDefaultChannel, retrieveTemporaryBuffer

Methods inherited from class java.io.OutputStream

nullOutputStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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

Field Details

out

protected final OutputStream out

Constructor Details

WrappedDataOutputStreamPlus

public WrappedDataOutputStreamPlus(OutputStream out)

WrappedDataOutputStreamPlus

public WrappedDataOutputStreamPlus(OutputStream out,
 WritableByteChannel channel)

Method Details

write

public void write(byte[] buffer,
 int offset,
 int count)
           throws IOException

Description copied from class: UnbufferedDataOutputStreamPlus

Writes count bytes from the byte array buffer starting at offset to this RandomAccessFile starting at the current file pointer..

Specified by:

write in interface DataOutput

Specified by:

write in class UnbufferedDataOutputStreamPlus

Parameters:

buffer - the bytes to be written

offset - offset in buffer to get bytes

count - number of bytes in buffer to write

Throws:

IOException - If an error occurs attempting to write to this RandomAccessFile.

write

public void write(int oneByte)
           throws IOException

Description copied from class: UnbufferedDataOutputStreamPlus

Writes the specified byte oneByte to this RandomAccessFile starting at the current file pointer. Only the low order byte of oneByte is written.

Specified by:

write in interface DataOutput

Specified by:

write in class UnbufferedDataOutputStreamPlus

Parameters:

oneByte - the byte to be written

Throws:

IOException - If an error occurs attempting to write to this RandomAccessFile.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException