Package | Description |
---|---|
org.apache.paimon.data | |
org.apache.paimon.data.serializer | |
org.apache.paimon.disk | |
org.apache.paimon.io.cache |
Modifier and Type | Class and Description |
---|---|
class |
RandomAccessInputView
A
AbstractPagedInputView to read pages in memory. |
Modifier and Type | Method and Description |
---|---|
void |
BinaryRowSerializer.checkSkipReadForFixLengthPart(AbstractPagedInputView source)
We need skip bytes to read when the remain bytes of current segment is not enough to write
binary row fixed part.
|
void |
BinaryRowSerializer.copyFromPagesToView(AbstractPagedInputView source,
DataOutputView target)
Copy a binaryRow which stored in paged input view to output view.
|
T |
PagedTypeSerializer.deserializeFromPages(AbstractPagedInputView source)
De-serializes a record from the given source paged input view.
|
BinaryRow |
BinaryRowSerializer.deserializeFromPages(AbstractPagedInputView headerLessView) |
InternalRow |
InternalRowSerializer.deserializeFromPages(AbstractPagedInputView source) |
BinaryRow |
BinaryRowSerializer.deserializeFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
InternalRow |
InternalRowSerializer.deserializeFromPages(InternalRow reuse,
AbstractPagedInputView source) |
T |
PagedTypeSerializer.deserializeFromPages(T reuse,
AbstractPagedInputView source)
Reuse version of
PagedTypeSerializer.deserializeFromPages(AbstractPagedInputView) . |
BinaryRow |
BinaryRowSerializer.mapFromPages(BinaryRow reuse,
AbstractPagedInputView headerLessView) |
InternalRow |
InternalRowSerializer.mapFromPages(InternalRow reuse,
AbstractPagedInputView source) |
T |
PagedTypeSerializer.mapFromPages(T reuse,
AbstractPagedInputView source)
Map a reused record from the given source paged input view.
|
void |
BinaryRowSerializer.pointTo(int length,
BinaryRow reuse,
AbstractPagedInputView headerLessView)
Point row to memory segments with offset(in the AbstractPagedInputView) and length.
|
void |
PagedTypeSerializer.skipRecordFromPages(AbstractPagedInputView source)
Skip over bytes of one record from the paged input view, discarding the skipped bytes.
|
void |
BinaryRowSerializer.skipRecordFromPages(AbstractPagedInputView headerLessView) |
void |
InternalRowSerializer.skipRecordFromPages(AbstractPagedInputView source) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelReaderInputView
A
DataInputView that is backed by a BufferFileReader , making it effectively a
data input stream. |
Modifier and Type | Class and Description |
---|---|
class |
FileBasedRandomInputView
A
SeekableDataInputView to read bytes from RandomAccessFile , the bytes can be
cached to MemorySegment s in CacheManager . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.