org.apache.cassandra.io.util

Class CompressedSegmentedFile

java.lang.Object

org.apache.cassandra.utils.concurrent.SharedCloseableImpl

org.apache.cassandra.io.util.SegmentedFile

org.apache.cassandra.io.util.CompressedSegmentedFile

All Implemented Interfaces:

java.lang.AutoCloseable, ICompressedFile, SharedCloseable

public class CompressedSegmentedFile
extends SegmentedFile
implements ICompressedFile

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CompressedSegmentedFile.Builder
static class	CompressedSegmentedFile.CompressedChunkReader

Field Summary

Fields

Modifier and Type	Field and Description
CompressionMetadata	metadata

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

channel, onDiskLength

Constructor Summary

Constructors

Constructor and Description
CompressedSegmentedFile(ChannelProxy channel, CompressionMetadata metadata, Config.DiskAccessMode mode)
CompressedSegmentedFile(ChannelProxy channel, CompressionMetadata metadata, MmappedRegions regions)
CompressedSegmentedFile(ChannelProxy channel, CompressionMetadata metadata, MmappedRegions regions, RebuffererFactory rebufferer)

Method Summary

Modifier and Type	Method and Description
void	addTo(Ref.IdentityCollection identities)
ChannelProxy	channel()
static ChunkReader	chunkReader(ChannelProxy channel, CompressionMetadata metadata, MmappedRegions regions)
long	dataLength()
void	dropPageCache(long before)
CompressionMetadata	getMetadata()
CompressedSegmentedFile	sharedCopy()

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

createReader, createReader, createReader, getBuilder, getCompressedBuilder, path, rebuffererFactory, toString

Methods inherited from class org.apache.cassandra.utils.concurrent.SharedCloseableImpl

close, close, isCleanedUp

Methods inherited from class java.lang.Object

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

Field Detail

metadata

public final CompressionMetadata metadata

Constructor Detail

CompressedSegmentedFile

public CompressedSegmentedFile(ChannelProxy channel,
                               CompressionMetadata metadata,
                               Config.DiskAccessMode mode)

CompressedSegmentedFile

public CompressedSegmentedFile(ChannelProxy channel,
                               CompressionMetadata metadata,
                               MmappedRegions regions)

CompressedSegmentedFile

public CompressedSegmentedFile(ChannelProxy channel,
                               CompressionMetadata metadata,
                               MmappedRegions regions,
                               RebuffererFactory rebufferer)

Method Detail

chunkReader

public static ChunkReader chunkReader(ChannelProxy channel,
                                      CompressionMetadata metadata,
                                      MmappedRegions regions)

channel

public ChannelProxy channel()

Specified by:

channel in interface ICompressedFile

sharedCopy

public CompressedSegmentedFile sharedCopy()

Specified by:

sharedCopy in interface SharedCloseable

Specified by:

sharedCopy in class SegmentedFile

Returns:

a new instance of the object representing the same state and backed by the same underlying resources. Coordinates with the original (and other instances) when the underlying resource should be closed. Throws an exception if the shared resource has already been closed.

addTo

public void addTo(Ref.IdentityCollection identities)

Specified by:

addTo in interface SharedCloseable

Overrides:

addTo in class SharedCloseableImpl

dropPageCache

public void dropPageCache(long before)

Overrides:

dropPageCache in class SegmentedFile

getMetadata

public CompressionMetadata getMetadata()

Specified by:

getMetadata in interface ICompressedFile

dataLength

public long dataLength()

Overrides:

dataLength in class SegmentedFile