Modifier and Type | Class and Description |
---|---|
class |
FileChannelInputView
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
class |
RandomAccessInputView |
class |
SeekableFileChannelInputView
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannelReaderInputView
A
DataInputView that is backed by a FileIOChannel ,
making it effectively a data input stream. |
class |
ChannelReaderInputView
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
class |
HeaderlessChannelReaderInputView
A
DataInputView that is backed by a BlockChannelReader , making it effectively a data input stream. |
Modifier and Type | Class and Description |
---|---|
class |
HashPartition<BT,PT> |
class |
ReOpenableHashPartition<BT,PT> |
Modifier and Type | Class and Description |
---|---|
class |
BinaryHashPartition
A partition.
|
class |
LongHashPartition
Partition for
LongHybridHashTable . |
Modifier and Type | Class and Description |
---|---|
class |
CompressedHeaderlessChannelReaderInputView
A
DataInputView that is backed by a BufferFileReader , making it effectively a data input stream. |
Modifier and Type | Method and Description |
---|---|
void |
BinaryRowDataSerializer.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 |
BinaryRowDataSerializer.copyFromPagesToView(AbstractPagedInputView source,
DataOutputView target)
Copy a binaryRow which stored in paged input view to output view.
|
BinaryRowData |
BinaryRowDataSerializer.deserializeFromPages(AbstractPagedInputView headerLessView) |
abstract T |
PagedTypeSerializer.deserializeFromPages(AbstractPagedInputView source)
De-serializes a record from the given source paged input view.
|
WindowKey |
WindowKeySerializer.deserializeFromPages(AbstractPagedInputView source) |
RowData |
RowDataSerializer.deserializeFromPages(AbstractPagedInputView source) |
BinaryRowData |
BinaryRowDataSerializer.deserializeFromPages(BinaryRowData reuse,
AbstractPagedInputView headerLessView) |
RowData |
RowDataSerializer.deserializeFromPages(RowData reuse,
AbstractPagedInputView source) |
abstract T |
PagedTypeSerializer.deserializeFromPages(T reuse,
AbstractPagedInputView source)
Reuse version of
PagedTypeSerializer.deserializeFromPages(AbstractPagedInputView) . |
WindowKey |
WindowKeySerializer.deserializeFromPages(WindowKey reuse,
AbstractPagedInputView source) |
BinaryRowData |
BinaryRowDataSerializer.mapFromPages(BinaryRowData reuse,
AbstractPagedInputView headerLessView) |
RowData |
RowDataSerializer.mapFromPages(RowData reuse,
AbstractPagedInputView source) |
abstract T |
PagedTypeSerializer.mapFromPages(T reuse,
AbstractPagedInputView source)
Map a reused record from the given source paged input view.
|
WindowKey |
WindowKeySerializer.mapFromPages(WindowKey reuse,
AbstractPagedInputView source) |
void |
BinaryRowDataSerializer.pointTo(int length,
BinaryRowData reuse,
AbstractPagedInputView headerLessView)
Point row to memory segments with offset(in the AbstractPagedInputView) and length.
|
void |
BinaryRowDataSerializer.skipRecordFromPages(AbstractPagedInputView headerLessView) |
abstract void |
PagedTypeSerializer.skipRecordFromPages(AbstractPagedInputView source)
Skip over bytes of one record from the paged input view, discarding the skipped bytes.
|
void |
WindowKeySerializer.skipRecordFromPages(AbstractPagedInputView source) |
void |
RowDataSerializer.skipRecordFromPages(AbstractPagedInputView source) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.