Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.operation | |
org.apache.paimon.partition | |
org.apache.paimon.privilege | |
org.apache.paimon.table.source.snapshot |
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
FileStore.newScan() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractFileStoreScan
Default implementation of
FileStoreScan . |
class |
AppendOnlyFileStoreScan
|
class |
KeyValueFileStoreScan
|
Constructor and Description |
---|
AbstractFileStoreWrite(SnapshotManager snapshotManager,
FileStoreScan scan,
IndexMaintainer.Factory<T> indexFactory,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName,
int totalBuckets,
RowType partitionType,
int writerNumberMax,
boolean legacyPartitionName) |
AppendOnlyFileStoreWrite(FileIO fileIO,
RawFileSplitRead read,
long schemaId,
RowType rowType,
RowType partitionType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
AppendOnlyFixedBucketFileStoreWrite(FileIO fileIO,
RawFileSplitRead read,
long schemaId,
String commitUser,
RowType rowType,
RowType partitionType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
AppendOnlyUnawareBucketFileStoreWrite(FileIO fileIO,
RawFileSplitRead read,
long schemaId,
RowType rowType,
RowType partitionType,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
FileStoreCommitImpl(FileIO fileIO,
SchemaManager schemaManager,
String tableName,
String commitUser,
RowType partitionType,
String partitionDefaultName,
FileStorePathFactory pathFactory,
SnapshotManager snapshotManager,
ManifestFile.Factory manifestFileFactory,
ManifestList.Factory manifestListFactory,
IndexManifestFile.Factory indexManifestFileFactory,
FileStoreScan scan,
int numBucket,
MemorySize manifestTargetSize,
MemorySize manifestFullCompactionSize,
int manifestMergeMinCount,
boolean dynamicPartitionOverwrite,
Comparator<InternalRow> keyComparator,
String branchName,
StatsFileHandler statsFileHandler,
BucketMode bucketMode,
Integer manifestReadParallelism,
List<CommitCallback> commitCallbacks,
int commitMaxRetries) |
KeyValueFileStoreWrite(FileIO fileIO,
SchemaManager schemaManager,
TableSchema schema,
String commitUser,
RowType partitionType,
RowType keyType,
RowType valueType,
java.util.function.Supplier<Comparator<InternalRow>> keyComparatorSupplier,
java.util.function.Supplier<FieldsComparator> udsComparatorSupplier,
java.util.function.Supplier<RecordEqualiser> logDedupEqualSupplier,
MergeFunctionFactory<KeyValue> mfFactory,
FileStorePathFactory pathFactory,
Map<String,FileStorePathFactory> format2PathFactory,
SnapshotManager snapshotManager,
FileStoreScan scan,
IndexMaintainer.Factory<KeyValue> indexFactory,
DeletionVectorsMaintainer.Factory deletionVectorsMaintainerFactory,
CoreOptions options,
KeyValueFieldsExtractor extractor,
String tableName) |
MemoryFileStoreWrite(SnapshotManager snapshotManager,
FileStoreScan scan,
CoreOptions options,
RowType partitionType,
IndexMaintainer.Factory<T> indexFactory,
DeletionVectorsMaintainer.Factory dvMaintainerFactory,
String tableName) |
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
MetastoreClient metastoreClient) |
PartitionExpire(java.time.Duration expirationTime,
java.time.Duration checkInterval,
PartitionExpireStrategy strategy,
FileStoreScan scan,
FileStoreCommit commit,
MetastoreClient metastoreClient,
boolean endInputCheckPartitionExpire) |
Modifier and Type | Method and Description |
---|---|
List<PartitionEntry> |
PartitionValuesTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
List<PartitionEntry> |
PartitionUpdateTimeExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
abstract List<PartitionEntry> |
PartitionExpireStrategy.selectExpiredPartitions(FileStoreScan scan,
java.time.LocalDateTime expirationTime) |
Modifier and Type | Method and Description |
---|---|
FileStoreScan |
PrivilegedFileStore.newScan() |
Constructor and Description |
---|
SnapshotReaderImpl(FileStoreScan scan,
TableSchema tableSchema,
CoreOptions options,
SnapshotManager snapshotManager,
SplitGenerator splitGenerator,
java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer,
DefaultValueAssigner defaultValueAssigner,
FileStorePathFactory pathFactory,
String tableName,
IndexFileHandler indexFileHandler) |
Constructor and Description |
---|
SnapshotReaderImpl(FileStoreScan scan,
TableSchema tableSchema,
CoreOptions options,
SnapshotManager snapshotManager,
SplitGenerator splitGenerator,
java.util.function.BiConsumer<FileStoreScan,Predicate> nonPartitionFilterConsumer,
DefaultValueAssigner defaultValueAssigner,
FileStorePathFactory pathFactory,
String tableName,
IndexFileHandler indexFileHandler) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.