Class ChunksBuffer
java.lang.Object
one.microstream.persistence.binary.types.Binary
one.microstream.persistence.binary.types.ChunksBuffer
- All Implemented Interfaces:
Chunk
,MemoryRangeReader
- Direct Known Subclasses:
ChunksBufferByteReversing
public class ChunksBuffer extends Binary implements MemoryRangeReader
-
Constructor Summary
Constructors Constructor Description ChunksBuffer()
-
Method Summary
Modifier and Type Method Description ByteBuffer[]
buffers()
Binary
channelChunk(int channelIndex)
int
channelCount()
void
clear()
ChunksBuffer
complete()
boolean
isEmpty()
void
iterateChannelChunks(Consumer<? super Binary> logic)
void
iterateEntityData(BinaryEntityDataReader reader)
long
iterateReferences(BinaryReferenceTraverser[] traversers, PersistenceObjectIdAcceptor acceptor)
long
loadItemEntityContentAddress()
void
modifyLoadItem(ByteBuffer directByteBuffer, long offset, long entityTotalLength, long entityTypeId, long entityObjectId)
static ChunksBuffer
New(ChunksBuffer[] channelBuffers, BufferSizeProviderIncremental bufferSizeProvider)
void
readMemory(long address, long length)
It is completely the caller's responsibility that the passed array contains a valid [LEN][TID][OID][data] byte sequence.void
storeEntityHeader(long entityContentLength, long entityTypeId, long entityObjectId)
long
totalLength()
Methods inherited from class one.microstream.persistence.binary.types.Binary
binaryListMaximumLength, binaryListMinimumLength, build_booleans, build_booleans, build_bytes, build_bytes, build_chars, build_chars, build_doubles, build_doubles, build_floats, build_floats, build_ints, build_ints, build_longs, build_longs, build_shorts, build_shorts, buildBoolean, buildBoolean, buildByte, buildByte, buildCharacter, buildCharacter, buildDouble, buildDouble, buildFloat, buildFloat, buildInteger, buildInteger, buildLong, buildLong, buildPrimitiveWrapper, buildPrimitiveWrapper, buildRootMapping, buildShort, buildShort, buildString, buildString, buildStrings, calculateBinaryLengthChars, calculateReferenceListTotalBinaryLength, calculateStringListContentBinaryLength, collectElementsIntoArray, collectKeyValueReferences, collectListObjectReferences, collectObjectReferences, copyMemory, create_booleans, create_booleans, create_bytes, create_bytes, create_chars, create_chars, create_doubles, create_doubles, create_floats, create_floats, create_ints, create_ints, create_longs, create_longs, create_shorts, create_shorts, entityContentLength, entityHeaderLength, entityTotalLength, Field, Field, Field_boolean, Field_boolean, Field_byte, Field_byte, Field_char, Field_char, Field_double, Field_double, Field_float, Field_float, Field_int, Field_int, Field_long, Field_long, Field_short, Field_short, getBinaryListElementCountUnvalidating, getBinaryListElementCountValidating, getBinaryListTotalByteLength, getBuildItemContentLength, getBuildItemObjectId, getBuildItemTotalLength, getBuildItemTypeId, getEntityLengthRawValue, getEntityObjectIdRawValue, getEntityTypeIdRawValue, getHelper, getListElementCount, getListElementCountKeyValue, getListElementCountReferences, getLoadItemAvailableContentLength, getSizedArrayElementCount, getSizedArrayElementsAddress, getSizedArrayLength, isSwitchedByteOrder, isValidEntityLength, isValidGapLength, iterateKeyValueEntriesReferences, iterateListElementReferences, iterateListStructureElements, iterateListStructureReferenceRange, iterateReferenceRange, iterateReferenceRangeUnvalidated, iterateSizedArrayElementReferences, keyValueBinaryLength, keyValueReferenceCount, lengthLength, objectIdByteLength, read_boolean, read_byte, read_char, read_double, read_float, read_int, read_long, read_short, referenceBinaryLength, registerHelper, store_boolean, store_boolean, store_booleans, store_byte, store_byte, store_bytes, store_char, store_char, store_chars, store_double, store_double, store_doubles, store_float, store_float, store_floats, store_int, store_int, store_ints, store_long, store_long, store_longs, store_short, store_short, store_shorts, storeBoolean, storeByte, storeCharacter, storeCharsAsList, storeDouble, storeFixedSize, storeFloat, storeInteger, storeIterableAsList, storeIterableContentAsList, storeKeyValuesAsEntries, storeKeyValuesAsEntries, storeListHeader, storeLong, storeMapEntrySet, storeReferences, storeReferences, storeReferencesAsList, storeRoots, storeShort, storeSizedArray, storeSizedArray, storeStateless, storeStringsAsList, storeStringsAsList, storeStringSingleValue, storeStringSingleValue, storeStringSingleValue, storeStringValue, storeStringValue, storeStringValue, toBinaryListByteLengthOffset, toBinaryListContentByteLength, toBinaryListElementCountOffset, toBinaryListElementsOffset, toBinaryListTotalByteLength, toEntityContentOffset, TypeHandler, TypeHandler, update_booleans, update_booleans, update_bytes, update_bytes, update_chars, update_chars, update_doubles, update_doubles, update_floats, update_floats, update_ints, update_ints, update_longs, update_longs, update_shorts, update_shorts, updateArrayObjectReferences, updateArrayObjectReferences1, updateFixedSize, updateSizedArrayObjectReferences, validateArrayLength
-
Constructor Details
-
ChunksBuffer
public ChunksBuffer()
-
-
Method Details
-
New
public static ChunksBuffer New(ChunksBuffer[] channelBuffers, BufferSizeProviderIncremental bufferSizeProvider) -
channelChunk
- Specified by:
channelChunk
in classBinary
-
channelCount
public final int channelCount()- Specified by:
channelCount
in classBinary
-
clear
public final void clear() -
readMemory
public void readMemory(long address, long length)It is completely the caller's responsibility that the passed array contains a valid [LEN][TID][OID][data] byte sequence.- Specified by:
readMemory
in interfaceMemoryRangeReader
-
storeEntityHeader
public final void storeEntityHeader(long entityContentLength, long entityTypeId, long entityObjectId)- Specified by:
storeEntityHeader
in classBinary
-
buffers
-
complete
-
iterateEntityData
- Specified by:
iterateEntityData
in classBinary
-
iterateChannelChunks
- Specified by:
iterateChannelChunks
in classBinary
-
isEmpty
public final boolean isEmpty() -
totalLength
public final long totalLength()- Specified by:
totalLength
in interfaceChunk
-
loadItemEntityContentAddress
public final long loadItemEntityContentAddress() -
modifyLoadItem
public final void modifyLoadItem(ByteBuffer directByteBuffer, long offset, long entityTotalLength, long entityTypeId, long entityObjectId)- Specified by:
modifyLoadItem
in classBinary
-
iterateReferences
public long iterateReferences(BinaryReferenceTraverser[] traversers, PersistenceObjectIdAcceptor acceptor)- Specified by:
iterateReferences
in classBinary
-