|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
BlockPool.getFreeBlock()
or BlockPool.removeBlock(int, int, int, long)
.
DefaultBlockPool
s 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.
Record
s within the database.DataStreamIndex
.DefaultBlockPool.getFreeBlock()
.StreamInterval
through an
array of ElementInterval
objects.DefaultStreamReconstructor
s.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)
.
IndexBlock
s that can be read.
Range
s 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
.IndexBlock
s.Record
s from an DBIterator
through a
StreamReconstructor
to generate a sequence of StreamInterval
s.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?).Range
s.RangeReader
s.RDBDefinitionParser
creates.BlockFile.getBlockSize()
.
ElementCompressor
s needed to compress all of the
elements of a Record for a DataStream.DataStream.readRecords()
.
DataStream.readRecords(long, long)
.
AbstractElementCodec.checkParams(Map)
.
Record
s 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 |