Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



#Com.bigdata.io Classes and Interfaces - 109 results found.
NameDescriptionTypePackageFramework
AbstractFixedByteArrayBufferEfficient absolute get/put operations on a slice of a byte[].Classcom.bigdata.ioBlazeGraph
AbstractRecordCompressorTestCaseAbstract base class for IRecordCompressor test suites.Classcom.bigdata.io.compressionBlazeGraph
AllocationDataUtility class to handle Compression and Checksums on a ByteArraySlice The idea is that it would be used as a "state-aware" buffer that could beClasscom.bigdata.ioBlazeGraph
BOCU1CompressorClasscom.bigdata.io.compressionBlazeGraph
BufferedWriteThe BufferedWrite merges/elides sorted scattered writes to minimize IO requests and maximize IO rates.Classcom.bigdata.io.writecacheBlazeGraph
ByteArrayBufferA view on a mutable byte[] that may be extended.Classcom.bigdata.ioBlazeGraph
ByteBufferInputStreamReads bytes from a ByteBuffer.Classcom.bigdata.ioBlazeGraph
ByteBufferOutputStreamWrites bytes onto a ByteBuffer.Classcom.bigdata.ioBlazeGraph
ByteCountInputStreamInput stream which reports the #of bytes read from the underlying stream.Classcom.bigdata.ioBlazeGraph
ByteCountOutputStreamOutput stream which reports the #of bytes read from the underlying stream.Classcom.bigdata.ioBlazeGraph
ChecksumUtilityUtility class for computing the Adler32 checksum of a buffer.Classcom.bigdata.ioBlazeGraph
CompressorRegistryRegistration pattern for IRecordCompressor implementations.Classcom.bigdata.io.compressionBlazeGraph
DataInputBufferA fast implementation of DataInput designed to read from a byte[].Classcom.bigdata.ioBlazeGraph
DataOutputBufferFast special purpose serialization onto a managed byte[] buffer conforming to the DataOutput API.Classcom.bigdata.ioBlazeGraph
DefaultRecordCompressorFactoryA serializable compression provider based on RecordCompressor.Classcom.bigdata.io.compressionBlazeGraph
DirectBufferPoolAn instance of this class manages a JVM-wide pool of direct (aka native) ByteBuffers.Classcom.bigdata.ioBlazeGraph
DirectBufferPool .OptionsOptions for provisioning the static instance of the Note: Since the DirectBufferPool.Interfacecom.bigdata.ioBlazeGraph
DirectBufferPoolAllocatorAn allocator for ByteBuffer slices backed by direct ByteBuffers allocated against a DirectBufferPool.Classcom.bigdata.ioBlazeGraph
DirectBufferPoolAllocator .IAllocationAn allocation against a direct ByteBuffer.Interfacecom.bigdata.ioBlazeGraph
DirectBufferPoolAllocator .IAllocationContextAn allocation context links some application specified key with a list of direct ByteBuffers on which allocations have been made byInterfacecom.bigdata.ioBlazeGraph
DirectBufferPoolTestHelperSome helper methods for CI.Classcom.bigdata.ioBlazeGraph
FileChannelUtilityA helper class for operations on FileChannels.Classcom.bigdata.ioBlazeGraph
FileChannelUtility .ReopenerInputStreamClasscom.bigdata.ioBlazeGraph
FileLockUtilityUtility methods for managing exlusive FileLocks and advisory locks depending on what is supported by the platform, file access mode, and volumeClasscom.bigdata.ioBlazeGraph
FixedByteArrayBufferEfficient absolute get/put operations on a slice of a byte[].Classcom.bigdata.ioBlazeGraph
GZipCompressorClasscom.bigdata.io.compressionBlazeGraph
IBackingReaderA backing reader can be provided to a WriteCacheService which can use the readRaw callback method as part of an encapsulated cachingInterfacecom.bigdata.io.writecacheBlazeGraph
IBufferAccessInterface for access to, and release of, a direct ByteBuffer managed by the DirectBufferPool.Interfacecom.bigdata.ioBlazeGraph
IBufferedWriterInterfacecom.bigdata.io.writecacheBlazeGraph
IByteArrayBufferAn interface for reading from and accessing a managed byte[] with access methods similar to those of ByteBuffer.Interfacecom.bigdata.ioBlazeGraph
IByteArraySliceInterface for a slice of a backing byte[].Interfacecom.bigdata.ioBlazeGraph
IDataRecordAn interface for absolute get/put operations on a slice of a byte[].Interfacecom.bigdata.ioBlazeGraph
IDataRecordAccessInterface for higher level data objects providing access to their backingVersion:$Id$Author:Bryan ThompsonInterfacecom.bigdata.ioBlazeGraph
IFixedDataRecordInterface adds some methods for stream-based access to IDataRecord.Interfacecom.bigdata.ioBlazeGraph
IManagedByteArrayAn interface for a managed byte[].Interfacecom.bigdata.ioBlazeGraph
IRecordCompressorInterface for record-level compression.Interfacecom.bigdata.io.compressionBlazeGraph
IRecordCompressorFactoryA factory for IRecordCompressors.Interfacecom.bigdata.io.compressionBlazeGraph
IRecordSerializerAn abstraction for serializing and de-serializing objects as byte[]s.Interfacecom.bigdata.ioBlazeGraph
IReopenChannelInterface for objects which know how to re-open a Channel for some resource and also understand when the resource has been closed and thereforeInterfacecom.bigdata.ioBlazeGraph
IStreamSerializerAn abstraction for serializing and de-serializing objects on streams.Interfacecom.bigdata.ioBlazeGraph
IUnicodeCompressorUnicode compression / decompression api.Interfacecom.bigdata.io.compressionBlazeGraph
IWriteCacheInterface for a write cache with read back and the capability to update records while they are still in the cache.Interfacecom.bigdata.io.writecacheBlazeGraph
IWriteCacheCountersInterface declaring the counters exposed by the WriteCache.Interfacecom.bigdata.io.writecacheBlazeGraph
IWriteCacheServiceCountersInterface declaring the counters exposed by the WriteCacheService .Interfacecom.bigdata.io.writecacheBlazeGraph
LongPackerPacking utility for non-negative long values.Classcom.bigdata.ioBlazeGraph
LongPacker .IByteBufferNarrow interface to support packing against different buffer classes.Interfacecom.bigdata.ioBlazeGraph
LongPackerTestCaseTestAll suite for LongPacker.Classcom.bigdata.ioBlazeGraph
ManagedByteArrayOutputStreamWraps an IManagedByteArray as an OutputStream.Classcom.bigdata.ioBlazeGraph
MergeStreamWithSnapshotDataThis utility class provide a method to write an InputStream to an OutputStream, merging with The ISnapshotData provides access to an ordered iteration of [Address,Data] that is processedClasscom.bigdata.ioBlazeGraph
MergeStreamWithSortedSetClasscom.bigdata.ioBlazeGraph
NameAndExtensionFilterHelper class to filter for files with a known basename and extension.Classcom.bigdata.ioBlazeGraph
NoCompressorNo compression version.Classcom.bigdata.io.compressionBlazeGraph
NOPRecordCompressorA compressor that copies bytes without compression them.Classcom.bigdata.io.compressionBlazeGraph
NOPReopener closed.Classcom.bigdata.ioBlazeGraph
NullOutputStreamAn OutputStream which discards anything written on it.Classcom.bigdata.ioBlazeGraph
ObjectSocketChannelStreamUtility class that provides dual Channel/ObjectStream access.Classcom.bigdata.ioBlazeGraph
RecordCompressorBulk data (de-)compressor used for leaves in IndexSegments.Classcom.bigdata.io.compressionBlazeGraph
SCSUCompressorClasscom.bigdata.io.compressionBlazeGraph
SerializerUtilHelper utilities for (de-)serialization of Serializable objects using the Java serialization mechanisms.Classcom.bigdata.ioBlazeGraph
ShortPackerPacking utility for non-negative short values.Classcom.bigdata.ioBlazeGraph
ShortPackerTestCaseTestAll suite for ShortPacker.Classcom.bigdata.ioBlazeGraph
SliceInputStreamA stream which only lets you read a fixed #of bytes from an underlyingVersion:$Id$Author:Bryan ThompsonClasscom.bigdata.ioBlazeGraph
TestAllAggregates test suites into increasing dependency order.Classcom.bigdata.io.compressionBlazeGraph
TestAllAggregates test suites in increasing dependency order.Classcom.bigdata.ioBlazeGraph
TestAllAggregates test suites in increasing dependency order.Classcom.bigdata.io.writecacheBlazeGraph
TestAll_BuffersAggregates test suites in increasing dependency order.Classcom.bigdata.ioBlazeGraph
TestAll_PackersClasscom.bigdata.ioBlazeGraph
TestByteArrayBufferTest suite for ByteArrayBuffer.Classcom.bigdata.ioBlazeGraph
TestByteBufferStreamsTest suite for classes that let us treat a ByteBuffer as an InputStream or an OutputStream.Classcom.bigdata.ioBlazeGraph
TestCase3Base class for some assertEquals methods not covered by TestCase or TestCase2.Classcom.bigdata.ioBlazeGraph
TestChecksumUtilityTest suite for ChecksumUtility.Classcom.bigdata.ioBlazeGraph
TestCompressorRegistryClasscom.bigdata.io.compressionBlazeGraph
TestDataOutputBufferTest suite for DataOutputBuffer.Classcom.bigdata.ioBlazeGraph
TestDirectBufferPoolTest suite for DirectBufferPool.Classcom.bigdata.ioBlazeGraph
TestDirectBufferPoolAllocatorTest suite for DirectBufferPoolAllocator.Classcom.bigdata.ioBlazeGraph
TestFileChannelUtilityTest suite for FileChannelUtility.Classcom.bigdata.ioBlazeGraph
TestFileLockUtilityTest suite for FileLockUtility.Classcom.bigdata.ioBlazeGraph
TestFixedByteArrayBufferTest suite for FixedByteArrayBuffer.Classcom.bigdata.ioBlazeGraph
TestHuffmanEncoderExplores the built-in huffman coding support in the Deflate library.Classcom.bigdata.io.compressionBlazeGraph
TestHuffmanEncoder .HuffmanDecoder Instances of this class are NOT thread-safe.Classcom.bigdata.io.compressionBlazeGraph
TestHuffmanEncoder .HuffmanEncoder standard.Classcom.bigdata.io.compressionBlazeGraph
TestIOLow level IO performance tests in support of bigdata design options.Classcom.bigdata.ioBlazeGraph
TestLongPackerTest suite for packing and unpacking unsigned long integers using the DataInputBuffer and the ByteArrayBuffer.Classcom.bigdata.ioBlazeGraph
TestManagedReadsInvestigates 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.Classcom.bigdata.ioBlazeGraph
TestMergeMapOutputTests the utility to merge an input stream with a sorted set of Author:Martyn CutcherClasscom.bigdata.ioBlazeGraph
TestNameAndExtensionFilterTest suite for NameAndExtensionFilter.Classcom.bigdata.ioBlazeGraph
TestNOPRecordCompressorTest suite for NOPRecordCompressor.Classcom.bigdata.io.compressionBlazeGraph
TestRecordCompressor_BestCompressionTest suite for RecordCompressor.Classcom.bigdata.io.compressionBlazeGraph
TestRecordCompressor_BestSpeedTest suite for RecordCompressor.Classcom.bigdata.io.compressionBlazeGraph
TestRWWriteCacheServiceTest suite for the WriteCacheService using scattered writes on aVersion:$Id: TestWriteCacheService.Classcom.bigdata.io.writecacheBlazeGraph
TestShortPackerTest suite for packing and unpacking unsigned short integers using the DataInputBuffer and the ByteArrayBuffer.Classcom.bigdata.ioBlazeGraph
TestSliceInputStreamTest suite for SliceInputStream.Classcom.bigdata.ioBlazeGraph
TestUnicodeCompressorUnit tests for Unicode schemes: Standard Compression for Unicode ()Byte Order Compression for Unicode ( BOCU ).Classcom.bigdata.io.compressionBlazeGraph
TestUnicodeHelperTest suite for UnicodeHelper.Classcom.bigdata.io.compressionBlazeGraph
TestWORMWriteCacheServiceTest suite for the WriteCacheService using pure append writes.Classcom.bigdata.io.writecacheBlazeGraph
TestWriteCacheTest suite for the WriteCache.Classcom.bigdata.io.writecacheBlazeGraph
TestWriteCacheServiceLifetimeThese tests exercise the lifetime semantics of a WriteCacheService.Classcom.bigdata.io.writecacheBlazeGraph
ThreadLocalRecordCompressorFactoryAn IRecordCompressorFactory with thread-local semantics based on an internal weak value cache and providing instances based on a delegateClasscom.bigdata.io.compressionBlazeGraph
UnicodeHelperUtility class for compressed unicode encode/decode.Classcom.bigdata.io.compressionBlazeGraph
WriteCacheThis class provides a write cache with read-through for NIO writes on a FileChannel (and potentially on a remote service).Classcom.bigdata.io.writecacheBlazeGraph
WriteCache .FileChannelScatteredWriteCacheThe scattered write cache is used by the RWStore since the writes can be made to any part of the file assigned for data allocation.Classcom.bigdata.io.writecacheBlazeGraph
WriteCache .FileChannelWriteCacheA WriteCache implementation suitable for an append-only file such as the WORMStrategy or the output file of theClasscom.bigdata.io.writecacheBlazeGraph
WriteCache .HAPackageUsed to retrieve the HAWriteMessage AND the associated This allows the WriteCache to compress the data and create theClasscom.bigdata.io.writecacheBlazeGraph
WriteCache .ReadCacheClasscom.bigdata.io.writecacheBlazeGraph
WriteCache .RecordMetadataThe metadata associated with a record in the WriteCache.Classcom.bigdata.io.writecacheBlazeGraph
WriteCacheCountersPerformance counters for the WriteCache.Classcom.bigdata.io.writecacheBlazeGraph
WriteCacheServiceA WriteCacheService is provisioned with some number of WriteCache buffers and a writer thread.Classcom.bigdata.io.writecacheBlazeGraph
WriteCacheService .AsynchronousCloseExceptionAn instance of this exception is thrown if a thread notices that the WriteCacheService was closed by a concurrent process.Classcom.bigdata.io.writecacheBlazeGraph
WriteCacheServiceCountersPerformance counters for the WriteCacheService.Classcom.bigdata.io.writecacheBlazeGraph