org.apache.cassandra.io.util

Class CompressedSegmentedFile.CompressedChunkReader

java.lang.Object

org.apache.cassandra.io.util.AbstractReaderFileProxy

org.apache.cassandra.io.util.CompressedSegmentedFile.CompressedChunkReader

All Implemented Interfaces:

java.lang.AutoCloseable, ChunkReader, ReaderFileProxy, RebuffererFactory

Enclosing class:

CompressedSegmentedFile

public abstract static class CompressedSegmentedFile.CompressedChunkReader
extends AbstractReaderFileProxy
implements ChunkReader

Field Summary

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

channel, fileLength

Constructor Summary

Constructors

Constructor and Description
CompressedChunkReader(ChannelProxy channel, CompressionMetadata metadata)

Method Summary

Modifier and Type	Method and Description
boolean	alignmentRequired() If true, positions passed to this rebufferer must be aligned to chunkSize.
int	chunkSize() Buffer size required for this rebufferer.
double	getCrcCheckChance() Needed for tests.
Rebufferer	instantiateRebufferer()
BufferType	preferredBufferType() Specifies type of buffer the caller should attempt to give.
java.lang.String	toString()

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

channel, close, fileLength

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

readChunk

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

channel, close, fileLength

Constructor Detail

CompressedChunkReader

public CompressedChunkReader(ChannelProxy channel,
                             CompressionMetadata metadata)

Method Detail

getCrcCheckChance

public double getCrcCheckChance()

Description copied from interface: ReaderFileProxy

Needed for tests. Returns the table's CRC check chance, which is only set for compressed tables.

Specified by:

getCrcCheckChance in interface ReaderFileProxy

Overrides:

getCrcCheckChance in class AbstractReaderFileProxy

toString

public java.lang.String toString()

Overrides:

toString in class AbstractReaderFileProxy

chunkSize

public int chunkSize()

Description copied from interface: ChunkReader

Buffer size required for this rebufferer. Must be power of 2 if alignment is required.

Specified by:

chunkSize in interface ChunkReader

alignmentRequired

public boolean alignmentRequired()

Description copied from interface: ChunkReader

If true, positions passed to this rebufferer must be aligned to chunkSize.

Specified by:

alignmentRequired in interface ChunkReader

preferredBufferType

public BufferType preferredBufferType()

Description copied from interface: ChunkReader

Specifies type of buffer the caller should attempt to give. This is not guaranteed to be fulfilled.

Specified by:

preferredBufferType in interface ChunkReader

instantiateRebufferer

public Rebufferer instantiateRebufferer()

Specified by:

instantiateRebufferer in interface RebuffererFactory