public abstract class AbstractIcebergCommitCallback extends Object implements CommitCallback
CommitCallback
to create Iceberg compatible metadata, so Iceberg readers can read
Paimon's RawFile
.Modifier and Type | Field and Description |
---|---|
protected FileStoreTable |
table |
Constructor and Description |
---|
AbstractIcebergCommitCallback(FileStoreTable table,
String commitUser) |
Modifier and Type | Method and Description |
---|---|
void |
call(List<ManifestEntry> committedEntries,
Snapshot snapshot) |
void |
close() |
void |
retry(ManifestCommittable committable) |
protected abstract boolean |
shouldAddFileToIceberg(DataFileMeta meta) |
protected final FileStoreTable table
public AbstractIcebergCommitCallback(FileStoreTable table, String commitUser)
public void close() throws Exception
close
in interface AutoCloseable
Exception
public void call(List<ManifestEntry> committedEntries, Snapshot snapshot)
call
in interface CommitCallback
public void retry(ManifestCommittable committable)
retry
in interface CommitCallback
protected abstract boolean shouldAddFileToIceberg(DataFileMeta meta)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.