Uses of Package
org.apache.cassandra.io.util
-
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.batchlog Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.cache Class Description ChunkReader RandomFileReader component that reads data from a file into a provided buffer and may have requirements over the size and alignment of reads.DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.FileHandle FileHandle
provides access to a file for reading, including the ones written by variousSequentialWriter
instances, and it is typically used bySSTableReader
.Memory An off-heap region of memory that must be manually free'd when no longer needed.RebuffererFactory Interface for the classes that can be used to instantiate rebufferers over a given file. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.config Class Description DiskOptimizationStrategy -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputBuffer An implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.FileDataInput FileHandle FileHandle
provides access to a file for reading, including the ones written by variousSequentialWriter
instances, and it is typically used bySSTableReader
.RandomAccessReader SequentialWriter Adds buffering, mark, and fsyncing to OutputStream. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.aggregation Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.columniterator Class Description FileDataInput FileHandle FileHandle
provides access to a file for reading, including the ones written by variousSequentialWriter
instances, and it is typically used bySSTableReader
. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.commitlog Class Description DataInputBuffer Input stream around a single ByteBuffer.DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataPosition FileDataInput FileSegmentInputStream This is the same as DataInputBuffer, i.e.RandomAccessReader RebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer.RewindableDataInput -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.filter Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.marshal Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.partitions Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.rows Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.FileDataInput -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.db.streaming Class Description ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.DataInputPlus Extension to DataInput that provides support for reading varintsDataIntegrityMetadata.ChecksumValidator DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.RebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.dht Class Description DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.exceptions Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.hints Class Description ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.RebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.index.sasi.disk Class Description DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.SequentialWriter Adds buffering, mark, and fsyncing to OutputStream. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.index.sasi.utils Class Description ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.RandomAccessReader -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.compress Class Description BufferedDataOutputStreamPlus An implementation of the DataOutputStreamPlus interface using a ByteBuffer to stage writes before flushing them to an underlying channel.DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.DataPosition Memory An off-heap region of memory that must be manually free'd when no longer needed.SequentialWriter Adds buffering, mark, and fsyncing to OutputStream.SequentialWriter.TransactionalProxy SequentialWriterOption SequentialWriter option -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.sstable Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DiskOptimizationStrategy FileDataInput Memory An off-heap region of memory that must be manually free'd when no longer needed.RandomAccessReader -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.sstable.format Class Description ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.CheckedFunction FileDataInput FileHandle FileHandle
provides access to a file for reading, including the ones written by variousSequentialWriter
instances, and it is typically used bySSTableReader
.RandomAccessReader -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.sstable.format.big Class Description DataInputPlus Extension to DataInput that provides support for reading varintsFileDataInput RandomAccessReader SequentialWriter Adds buffering, mark, and fsyncing to OutputStream. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.sstable.metadata Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.FileDataInput -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.io.util Class Description AbstractReaderFileProxy BufferedDataOutputStreamPlus An implementation of the DataOutputStreamPlus interface using a ByteBuffer to stage writes before flushing them to an underlying channel.BufferManagingRebufferer Buffer manager used for reading from a ChunkReader when cache is not in use.BytesReadTracker ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.ChunkReader RandomFileReader component that reads data from a file into a provided buffer and may have requirements over the size and alignment of reads.CompressedChunkReader DataInputBuffer Input stream around a single ByteBuffer.DataInputPlus Extension to DataInput that provides support for reading varintsDataIntegrityMetadata.ChecksumValidator DataIntegrityMetadata.FileDigestValidator DataOutputBuffer An implementation of the DataOutputStream interface using a FastByteArrayOutputStream and exposing its buffer so copies can be avoided.DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.DataPosition DiskOptimizationStrategy FileDataInput FileHandle FileHandle
provides access to a file for reading, including the ones written by variousSequentialWriter
instances, and it is typically used bySSTableReader
.FileHandle.Builder Configures how the file will be read (compressed, mmapped, use cache etc.)Memory An off-heap region of memory that must be manually free'd when no longer needed.MmappedRegions MmappedRegions.Region RandomAccessReader ReaderFileProxy Base class for the RandomAccessReader components that implement reading.Rebufferer Rebufferer for reading data by a RandomAccessReader.Rebufferer.BufferHolder RebuffererFactory Interface for the classes that can be used to instantiate rebufferers over a given file.RebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer.RewindableDataInput SafeMemory SafeMemoryWriter SequentialWriter Adds buffering, mark, and fsyncing to OutputStream.SequentialWriter.TransactionalProxy SequentialWriterOption SequentialWriter optionSequentialWriterOption.Builder UnbufferedDataOutputStreamPlus Base class for DataOutput implementations that does not have an optimized implementations of Plus methods and does no buffering. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.locator Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.net Class Description BufferedDataOutputStreamPlus An implementation of the DataOutputStreamPlus interface using a ByteBuffer to stage writes before flushing them to an underlying channel.DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream.RebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.repair Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.schema Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.security Class Description ChannelProxy A proxy of a FileChannel that: - implements reference counting - exports only thread safe FileChannel operations - wraps IO exceptions into runtime exceptions Tested by RandomAccessReaderTest.FileDataInput -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.service Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.service.paxos Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.streaming Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.streaming.async Class Description DataInputPlus Extension to DataInput that provides support for reading varints -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.streaming.compress Class Description DataInputPlus Extension to DataInput that provides support for reading varintsRebufferingInputStream Rough equivalent of BufferedInputStream and DataInputStream wrapping a ByteBuffer that can be refilled via rebuffer. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.streaming.messages Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead.DataOutputStreamPlus Abstract base class for DataOutputStreams that accept writes from ByteBuffer or Memory and also provide access to the underlying WritableByteChannel associated with their output stream. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.utils Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.utils.concurrent Class Description Memory An off-heap region of memory that must be manually free'd when no longer needed. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.utils.obs Class Description DataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.utils.streamhist Class Description DataInputPlus Extension to DataInput that provides support for reading varintsDataOutputPlus Extension to DataOutput that provides for writing ByteBuffer and Memory, potentially with an efficient implementation that is zero copy or at least has reduced bounds checking overhead. -
Classes in org.apache.cassandra.io.util used by org.apache.cassandra.utils.vint Class Description DataInputPlus Extension to DataInput that provides support for reading varints