Interface | Description |
---|---|
AtomicFileWriter |
The AtomicFileWriter creates
AtomicFsDataOutputStream .The streams do not make the files
they write to immediately visible, but instead write to temp files or other temporary storage. |
JsonSerializer<T> |
Json serializer for jackson.
|
RecordReader<T> |
The reader that reads the batches of records.
|
RecordReader.RecordIterator<T> |
An internal iterator interface which presents a more restrictive API than
Iterator . |
RecordWriter<T> |
The
RecordWriter is responsible for writing data and handling in-progress files used to
write yet un-staged data. |
RecordWriter.CommitIncrement |
Changes to commit.
|
Class | Description |
---|---|
AtomicFsDataOutputStream |
A stream initially writes to hidden files or temp files and only creates the target file once it
is closed and "committed".
|
BulkFormatMapping |
Class with index mapping and bulk format.
|
BulkFormatMapping.BulkFormatMappingBuilder |
Builder to build
BulkFormatMapping . |
FileStorePathFactory |
Factory which produces
Path s for manifest files. |
FileUtils |
Utils for file reading and writing.
|
IteratorRecordReader<T> |
Wrap a
Iterator as an RecordReader . |
JsonSerdeUtil |
A utility class that provide abilities for JSON serialization and deserialization.
|
KeyComparatorSupplier |
A
Supplier that returns the comparator for the file store key. |
ObjectSerializer<T> |
A serializer to serialize object by
RowDataSerializer . |
OffsetRowData |
A
RowData to wrap row with offset. |
RecordReaderIterator<T> |
Wrap a
RecordReader as an CloseableIterator . |
RecordReaderUtils |
Utils for
RecordReader . |
RecoverableAtomicFileWriter |
A
AtomicFileWriter to wrap RecoverableWriter . |
RenamingAtomicFsDataOutputStream |
A stream initially writes to hidden files or temp files and only creates the target file once it
is closed and "committed".
|
RowDataPartitionComputer |
PartitionComputer for
RowData . |
SerializationUtils |
Utils for serialization.
|
SnapshotManager |
Manager for
Snapshot , providing utility methods related to paths and snapshot hints. |
VersionedObjectSerializer<T> |
A
ObjectSerializer for versioned serialization. |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.