Package org.apache.cassandra.io.util

Class MemoryInputStream

java.lang.Object

java.io.InputStream

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

org.apache.cassandra.io.util.RebufferingInputStream

org.apache.cassandra.io.util.MemoryInputStream

All Implemented Interfaces:

Closeable, DataInput, AutoCloseable, DataInputPlus

public class MemoryInputStream
extends RebufferingInputStream
implements DataInput

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
MemoryInputStream(Memory mem)
MemoryInputStream(Memory mem, int bufferSize)

Method Summary

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

close, 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 java.io.Closeable

close

Methods inherited from interface java.io.DataInput

readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF

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

skipBytesFully

Constructor Details

MemoryInputStream

public MemoryInputStream(Memory mem)

MemoryInputStream

public MemoryInputStream(Memory mem,
 int bufferSize)

Method Details

reBuffer

protected void reBuffer()
                 throws IOException

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

Throws:

IOException

available

public int available()

Overrides:

available in class InputStream