Package com.bigdata.io

Interface Summary

Interface	Description
DirectBufferPool.Options	Options for provisioning the static instance of the DirectBufferPool.
DirectBufferPoolAllocator.IAllocation	An allocation against a direct ByteBuffer.
DirectBufferPoolAllocator.IAllocationContext	An allocation context links some application specified key with a list of direct ByteBuffers on which allocations have been made by the application.
FileChannelUtility.IAsyncOpener	Define interface to support callback from readAllAsync
IBufferAccess	Interface for access to, and release of, a direct ByteBuffer managed by the DirectBufferPool.
IByteArrayBuffer	An interface for reading from and accessing a managed byte[] with access methods similar to those of ByteBuffer.
IByteArraySlice	Interface for a slice of a backing byte[].
IDataRecord	An interface for absolute get/put operations on a slice of a byte[].
IDataRecordAccess	Interface for higher level data objects providing access to their backing IFixedDataRecord.
IFixedDataRecord	Interface adds some methods for stream-based access to IDataRecord.
IManagedByteArray	An interface for a managed byte[].
IRecordSerializer<T>	An abstraction for serializing and de-serializing objects as byte[]s.
IReopenChannel<C extends Channel>	Interface for objects which know how to re-open a Channel for some resource and also understand when the resource has been closed and therefore should not be reopened.
IStreamSerializer<T>	An abstraction for serializing and de-serializing objects on streams.
LongPacker.IByteBuffer	Narrow interface to support packing against different buffer classes.

Class Summary

Class	Description
AbstractFixedByteArrayBuffer	Efficient absolute get/put operations on a slice of a byte[].
AllocationData	Utility class to handle Compression and Checksums on a ByteArraySlice The idea is that it would be used as a "state-aware" buffer that could be saved/restored to/from an IDiskStrategy.
ByteArrayBuffer	A view on a mutable byte[] that may be extended.
ByteBufferInputStream	Reads bytes from a ByteBuffer.
ByteBufferOutputStream	Writes bytes onto a ByteBuffer.
ByteCountInputStream	Input stream which reports the #of bytes read from the underlying stream.
ByteCountOutputStream	Output stream which reports the #of bytes read from the underlying stream.
ChecksumUtility	Utility class for computing the Adler32 checksum of a buffer.
DataInputBuffer	A fast implementation of DataInput designed to read from a byte[].
DataOutputBuffer	Fast special purpose serialization onto a managed byte[] buffer conforming to the DataOutput API.
DirectBufferPool	An instance of this class manages a JVM-wide pool of direct (aka native) ByteBuffers.
DirectBufferPoolAllocator	An allocator for ByteBuffer slices backed by direct ByteBuffers allocated against a DirectBufferPool.
DirectBufferPoolTestHelper	Some helper methods for CI.
FileChannelUtility	A helper class for operations on FileChannels.
FileChannelUtility.AsyncTransfer	The AsyncTransfer class encapsulates the state required to make asynchronous transfer requests.
FileChannelUtility.ReopenerInputStream	An InputStream implementation that utilizes the resilient readAll method of this class
FileLockUtility	Deprecated This can lead to trouble.
FixedByteArrayBuffer	Efficient absolute get/put operations on a slice of a byte[].
LongPacker	Packing utility for non-negative long values.
LongPackerTestCase	TestAll suite for LongPacker.
ManagedByteArrayOutputStream	Wraps an IManagedByteArray as an OutputStream.
MergeStreamWithSnapshotData	This utility class provide a method to write an InputStream to an OutputStream, merging with the ISnapshotData.
MergeStreamWithSortedSet
NameAndExtensionFilter	Helper class to filter for files with a known basename and extension.
NOPReopener	Implementation that will not re-open the FileChannel once it has been closed.
NullOutputStream	An OutputStream which discards anything written on it.
ObjectSocketChannelStream	Utility class that provides dual Channel/ObjectStream access.
SerializerUtil	Helper utilities for (de-)serialization of Serializable objects using the Java serialization mechanisms.
ShortPacker	Packing utility for non-negative short values.
ShortPackerTestCase	TestAll suite for ShortPacker.
SliceInputStream	A stream which only lets you read a fixed #of bytes from an underlying stream.
TestAll	Aggregates test suites in increasing dependency order.
TestAll_Buffers	Aggregates test suites in increasing dependency order.
TestAll_Packers
TestByteArrayBuffer	Test suite for ByteArrayBuffer.
TestByteBufferStreams	Test suite for classes that let us treat a ByteBuffer as an InputStream or an OutputStream.
TestCase3	Base class for some assertEquals methods not covered by TestCase or TestCase2.
TestChecksumUtility	Test suite for ChecksumUtility.
TestDataOutputBuffer	Test suite for DataOutputBuffer.
TestDirectBufferPool	Test suite for DirectBufferPool.
TestDirectBufferPoolAllocator	Test suite for DirectBufferPoolAllocator.
TestFileChannelUtility	Test suite for FileChannelUtility.
TestFileLockUtility	Test suite for FileLockUtility.
TestFixedByteArrayBuffer	Test suite for FixedByteArrayBuffer.
TestIO	Low level IO performance tests in support of bigdata design options.
TestLongPacker	Test suite for packing and unpacking unsigned long integers using the DataInputBuffer and the ByteArrayBuffer.
TestManagedReads	Investigates the benefits (if any) of managed concurrent reads with the aim of developing metrics on which to base a ConcurrentReadManager for use by the Disk based strategies.
TestMergeMapOutput	Tests the utility to merge an input stream with a sorted set of
TestNameAndExtensionFilter	Test suite for NameAndExtensionFilter.
TestShortPacker	Test suite for packing and unpacking unsigned short integers using the DataInputBuffer and the ByteArrayBuffer.
TestSliceInputStream	Test suite for SliceInputStream.