Package | Description |
---|---|
org.apache.paimon | |
org.apache.paimon.iceberg | |
org.apache.paimon.metastore | |
org.apache.paimon.operation | |
org.apache.paimon.privilege | |
org.apache.paimon.table.sink |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
FileStore.newCommit(String commitUser,
List<CommitCallback> callbacks) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractIcebergCommitCallback
A
CommitCallback to create Iceberg compatible metadata, so Iceberg readers can read
Paimon's RawFile . |
class |
AppendOnlyIcebergCommitCallback
AbstractIcebergCommitCallback for append only tables. |
class |
PrimaryKeyIcebergCommitCallback
AbstractIcebergCommitCallback for primary key tables. |
Modifier and Type | Class and Description |
---|---|
class |
AddPartitionCommitCallback
A
CommitCallback to add newly created partitions to metastore. |
class |
TagPreviewCommitCallback
A
CommitCallback to add partitions to metastore for tag preview. |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
FileStoreCommit |
PrivilegedFileStore.newCommit(String commitUser,
List<CommitCallback> callbacks) |
Modifier and Type | Method and Description |
---|---|
static List<CommitCallback> |
CallbackUtils.loadCommitCallbacks(CoreOptions coreOptions) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.