Package org.apache.cassandra.io.util

Class DataInputBuffer

java.lang.Object

java.io.InputStream

org.apache.cassandra.io.util.DataInputPlus.DataInputStreamPlus

org.apache.cassandra.io.util.RebufferingInputStream

org.apache.cassandra.io.util.DataInputBuffer

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, DataInputPlus

Direct Known Subclasses:

FileSegmentInputStream

public class DataInputBuffer
extends RebufferingInputStream

Input stream around a single ByteBuffer.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.io.util.DataInputPlus

DataInputPlus.DataInputStreamPlus

Field Summary

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

buffer

Constructor Summary

Constructors

Constructor	Description
DataInputBuffer(byte[] buffer)
DataInputBuffer(byte[] buffer, int offset, int length)
DataInputBuffer(ByteBuffer buffer, boolean duplicate)

Method Summary

Modifier and Type	Method	Description
int	available()
void	close()
protected void	reBuffer()	Implementations must implement this method to refill the buffer.

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

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readFully, readInt, readLine, readLong, readPrimitiveSlowly, readShort, readUnsignedByte, readUnsignedShort, readUnsignedVInt, readUnsignedVInt32, readUTF, readVInt, readVInt32, skipBytes

Methods inherited from class java.io.InputStream

mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

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.DataInputPlus

skipBytesFully

Constructor Details

DataInputBuffer

public DataInputBuffer(ByteBuffer buffer,
 boolean duplicate)

Parameters:

buffer -

duplicate - Whether or not to duplicate the buffer to ensure thread safety

DataInputBuffer

public DataInputBuffer(byte[] buffer,
 int offset,
 int length)

DataInputBuffer

public DataInputBuffer(byte[] buffer)

Method Details

reBuffer

protected void reBuffer()

Description copied from class: RebufferingInputStream

Implementations must implement this method to refill the buffer. They can expect the buffer to be empty when this method is invoked.

Specified by:

reBuffer in class RebufferingInputStream

available

public int available()

Overrides:

available in class InputStream

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream