|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
BlockPool.getFreeBlock() or BlockPool.removeBlock(int, int, int, long).
DefaultBlockPools and the associated
CircularQueue and TransactionLog.DataStreamInfo.checkRecord(Record).
DataOutputWritable objects.DataBlockManager.getNextBlock(int), which schedules it to be written to
disk and marks the intention that no more data will be added to it.
DatabaseBuilder.createDatabase(File).
DefaultBlockPool.
DataSection.DataIndex.DataStreamIndex by using a DataStreamIndexReader.DataIndexSection.createNew(org.gillius.realdb.io.BlockFile, int, int, int, int) and DataIndexSection.load(org.gillius.realdb.io.BlockFile, int, int, int, int)
factory methods would be used.
Records within the database.DataStreamIndex.DefaultBlockPool.getFreeBlock().StreamInterval through an
array of ElementInterval objects.DefaultStreamReconstructors.DefaultTransaction.commit().DataOutputWritable objects.ElementSerializer objects that work with a specific
ElementType.IndexBlockFactory.addDataBlock(int, long, long) call, or the
'minStartTime' from the constructor if it has never been called.
CircularLog.getLastMessages() but filtered such that only log entries containing the
filter string appear are in the returned list.
BlockPool.hasFreeBlocks(), then returns a new transaction with the free block.
CircularLog.LOG_SIZE messages as a list.
ElementCompressor.handleNewValue(long[], java.lang.Object[], int).
ElementCompressor.handleNewValue(long[], java.lang.Object[], int).
IndexBlocks that can be read.
Ranges that can be read.
DatabaseStatistics, else returns
null.
Range of record times within all of the data blocks referenced by the
IndexBlock.
Range.
RecordBuffer.getSize().
DataOutputWritable.write(DataOutput).
SizingDataOutput.reset().
StreamInterval.getEndTime() - StreamInterval.getStartTime().
RecordWriter.writeRecord(Record, DataOutput).
IndexBlockFactory.addDataBlock(int, long, long) can safely be called on this factory, which is if
IndexBlockFactory.getNumIndices() < IndexBlockFactory.getMaxIndices().
DataIndex.IndexBlocks.Records from an DBIterator through a
StreamReconstructor to generate a sequence of StreamIntervals.DataStream.readIntervals().
DataStream.readIntervals(long, long).
DBIterator to read all of the data in this queue, using the given reader to
deserialize the elements.
DataBlock.getRawData(),
plus any number of random bytes.
DefaultBlockPool from the given BlockFile.
DataBlock.HEADER_SIZE bytes of the DataBlock's data, returns a DefaultRange.
ElementType that may or may not be specified (is it
nullable?).Ranges.RangeReaders.RDBDefinitionParser creates.BlockFile.getBlockSize().
ElementCompressors needed to compress all of the
elements of a Record for a DataStream.DataStream.readRecords().
DataStream.readRecords(long, long).
AbstractElementCodec.checkParams(Map).
Records and builds a sequence of StreamInterval objects from it.TxEntry.TxEntry objects.DataIndex.addDataBlock(int, long, long, Transaction).
IndexBlockFactory.addDataBlock(int, long, long).
FreeStateTxEntry.write(DataOutput) method, but without creating an
actual object, to reduce memory allocations.
BlockFile.getBlockSize().
BlockFile.writeBlocks(int, byte[], int, int) with start=0 and
len=data.length.
String.format(String, Object[]) method.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||