Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.iceberg.manifest | |
org.apache.paimon.index | |
org.apache.paimon.io | |
org.apache.paimon.manifest | |
org.apache.paimon.utils |
Modifier and Type | Class and Description |
---|---|
class |
KeyValueSerializer
Serializer for
KeyValue . |
Modifier and Type | Class and Description |
---|---|
class |
IcebergDataFileMetaSerializer
Serializer for
IcebergDataFileMeta . |
class |
IcebergManifestEntrySerializer
Serializer for
IcebergManifestEntry . |
class |
IcebergManifestFileMetaSerializer
Serializer for
IcebergManifestFileMeta . |
class |
IcebergPartitionSummarySerializer
Serializer for
IcebergPartitionSummary . |
Modifier and Type | Class and Description |
---|---|
class |
IndexFileMetaSerializer
|
Modifier and Type | Class and Description |
---|---|
class |
DataFileMetaSerializer
Serializer for
DataFileMeta . |
class |
IdentifierSerializer
Serializer for
Identifier . |
Modifier and Type | Class and Description |
---|---|
class |
IndexManifestEntrySerializer
|
class |
ManifestEntrySerializer
Serializer for
ManifestEntry . |
class |
ManifestFileMetaSerializer
Serializer for
ManifestFileMeta . |
class |
SimpleFileEntrySerializer
A
VersionedObjectSerializer for SimpleFileEntry , only supports reading. |
Modifier and Type | Class and Description |
---|---|
class |
IntObjectSerializer
A
ObjectSerializer for int. |
class |
KeyValueWithLevelNoReusingSerializer
Serializer for
KeyValue with Level. |
class |
VersionedObjectSerializer<T>
A
ObjectSerializer for versioned serialization. |
Modifier and Type | Field and Description |
---|---|
protected ObjectSerializer<T> |
ObjectsFile.serializer |
Modifier and Type | Method and Description |
---|---|
static <V> List<V> |
ObjectsFile.readFromIterator(CloseableIterator<InternalRow> inputIterator,
ObjectSerializer<V> serializer,
Filter<InternalRow> readFilter) |
Constructor and Description |
---|
ObjectsCache(SegmentsCache<K> cache,
ObjectSerializer<V> projectedSerializer,
RowType formatSchema,
FunctionWithIOException<K,Long> fileSizeFunction,
BiFunctionWithIOE<K,Long,CloseableIterator<InternalRow>> reader) |
ObjectsFile(FileIO fileIO,
ObjectSerializer<T> serializer,
RowType formatType,
FormatReaderFactory readerFactory,
FormatWriterFactory writerFactory,
String compression,
PathFactory pathFactory,
SegmentsCache<Path> cache) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.