org.apache.cassandra.hints

Class CompressedChecksummedDataInput

java.lang.Object

java.io.InputStream

org.apache.cassandra.io.util.RebufferingInputStream

org.apache.cassandra.io.util.RandomAccessReader

org.apache.cassandra.io.util.RandomAccessReader.RandomAccessReaderWithOwnChannel

org.apache.cassandra.hints.ChecksummedDataInput

org.apache.cassandra.hints.CompressedChecksummedDataInput

All Implemented Interfaces:

java.io.Closeable, java.io.DataInput, java.lang.AutoCloseable, DataInputPlus, FileDataInput, RewindableDataInput

public final class CompressedChecksummedDataInput
extends ChecksummedDataInput

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CompressedChecksummedDataInput.Builder

Nested classes/interfaces inherited from class org.apache.cassandra.io.util.RandomAccessReader

RandomAccessReader.BufferedRandomAccessFileMark, RandomAccessReader.RandomAccessReaderWithOwnChannel

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

bufferOffset, bufferSize, bufferType, channel, DEFAULT_BUFFER_SIZE, limiter, markedPointer, MAX_BUFFER_SIZE, regions

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

buffer

Constructor Summary

Constructors

Constructor and Description
CompressedChecksummedDataInput(CompressedChecksummedDataInput.Builder builder)

Method Summary

Modifier and Type	Method and Description
InputPosition	getSeekPosition() Return a seekable representation of the current position.
long	getSourcePosition() Returns the position in the source file, which is different for getPosition() for compressed/encrypted files and may be imprecise.
boolean	isEOF() Since an entire block of compressed data is read off of disk, not just a hint at a time, we don't report EOF until the decompressed data has also been read completely
protected void	reBufferMmap()
protected void	reBufferStandard()
protected void	releaseBuffer()
void	seek(InputPosition p)
static CompressedChecksummedDataInput	upgradeInput(ChecksummedDataInput input, ICompressor compressor)

Methods inherited from class org.apache.cassandra.hints.ChecksummedDataInput

bytesPastLimit, checkCrc, checkLimit, limit, open, read, readFully, reBuffer, resetCrc, resetLimit, tryUncacheRead

Methods inherited from class org.apache.cassandra.io.util.RandomAccessReader.RandomAccessReaderWithOwnChannel

close

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

allocateBuffer, available, bytesPastMark, bytesPastMark, bytesRemaining, current, getChannel, getFilePointer, getPath, getPosition, length, mark, markSupported, open, readLine, reset, reset, seek, toString

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

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

Methods inherited from class java.io.InputStream

mark, read, skip

Methods inherited from class java.lang.Object

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

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

readUnsignedVInt, readVInt, skipBytes, skipBytesFully

Methods inherited from interface java.io.DataInput

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

Constructor Detail

CompressedChecksummedDataInput

public CompressedChecksummedDataInput(CompressedChecksummedDataInput.Builder builder)

Method Detail

isEOF

public boolean isEOF()

Since an entire block of compressed data is read off of disk, not just a hint at a time, we don't report EOF until the decompressed data has also been read completely

Specified by:

isEOF in interface FileDataInput

Overrides:

isEOF in class RandomAccessReader

Returns:

true if there is no more data to read

getSourcePosition

public long getSourcePosition()

Description copied from class: ChecksummedDataInput

Returns the position in the source file, which is different for getPosition() for compressed/encrypted files and may be imprecise.

Overrides:

getSourcePosition in class ChecksummedDataInput

getSeekPosition

public InputPosition getSeekPosition()

Description copied from class: ChecksummedDataInput

Return a seekable representation of the current position. For compressed files this is chunk position in file and offset within chunk.

Overrides:

getSeekPosition in class ChecksummedDataInput

seek

public void seek(InputPosition p)

Overrides:

seek in class ChecksummedDataInput

reBufferStandard

protected void reBufferStandard()

Overrides:

reBufferStandard in class RandomAccessReader

releaseBuffer

protected void releaseBuffer()

Overrides:

releaseBuffer in class RandomAccessReader

reBufferMmap

protected void reBufferMmap()

Overrides:

reBufferMmap in class RandomAccessReader

upgradeInput

public static final CompressedChecksummedDataInput upgradeInput(ChecksummedDataInput input,
                                                                ICompressor compressor)