Uses of Class
org.apache.paimon.manifest.ManifestCommittable

Packages that use ManifestCommittable

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.partition
org.apache.paimon.iceberg
org.apache.paimon.manifest
org.apache.paimon.metastore
org.apache.paimon.operation
org.apache.paimon.table.sink

Uses of ManifestCommittable in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return ManifestCommittable

Modifier and Type	Method and Description
ManifestCommittable	StoreCommitter.combine(long checkpointId, long watermark, List<Committable> committables)
ManifestCommittable	StoreCommitter.combine(long checkpointId, long watermark, ManifestCommittable manifestCommittable, List<Committable> committables)

Methods in org.apache.paimon.flink.sink that return types with arguments of type ManifestCommittable

Modifier and Type	Method and Description
protected CommittableStateManager<ManifestCommittable>	UnawareBucketCompactionSink.createCommittableStateManager()
protected abstract CommittableStateManager<ManifestCommittable>	FlinkSink.createCommittableStateManager()
protected CommittableStateManager<ManifestCommittable>	FlinkWriteSink.createCommittableStateManager()
protected CommittableStateManager<ManifestCommittable>	CompactorSink.createCommittableStateManager()
protected Committer.Factory<Committable,ManifestCommittable>	UnawareBucketCompactionSink.createCommitterFactory()
protected abstract Committer.Factory<Committable,ManifestCommittable>	FlinkSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	FlinkWriteSink.createCommitterFactory()
protected Committer.Factory<Committable,ManifestCommittable>	CompactorSink.createCommitterFactory()

Methods in org.apache.paimon.flink.sink with parameters of type ManifestCommittable

Modifier and Type	Method and Description
ManifestCommittable	StoreCommitter.combine(long checkpointId, long watermark, ManifestCommittable manifestCommittable, List<Committable> committables)

Method parameters in org.apache.paimon.flink.sink with type arguments of type ManifestCommittable

Modifier and Type	Method and Description
void	StoreCommitter.commit(List<ManifestCommittable> committables)
int	StoreCommitter.filterAndCommit(List<ManifestCommittable> globalCommittables, boolean checkAppendFiles)
void	NoopCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context, Committer<?,ManifestCommittable> committer)
void	NoopCommittableStateManager.snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context, List<ManifestCommittable> committables)

Uses of ManifestCommittable in org.apache.paimon.flink.sink.partition

Method parameters in org.apache.paimon.flink.sink.partition with type arguments of type ManifestCommittable

Modifier and Type	Method and Description
void	PartitionMarkDone.notifyCommittable(List<ManifestCommittable> committables)

Uses of ManifestCommittable in org.apache.paimon.iceberg

Methods in org.apache.paimon.iceberg with parameters of type ManifestCommittable

Modifier and Type	Method and Description
void	AbstractIcebergCommitCallback.retry(ManifestCommittable committable)

Uses of ManifestCommittable in org.apache.paimon.manifest

Methods in org.apache.paimon.manifest that return ManifestCommittable

Modifier and Type	Method and Description
ManifestCommittable	WrappedManifestCommittable.computeCommittableIfAbsent(Identifier identifier, long checkpointId, long watermark)
ManifestCommittable	ManifestCommittableSerializer.deserialize(int version, byte[] serialized)

Methods in org.apache.paimon.manifest that return types with arguments of type ManifestCommittable

Modifier and Type	Method and Description
Map<Identifier,ManifestCommittable>	WrappedManifestCommittable.manifestCommittables()

Methods in org.apache.paimon.manifest with parameters of type ManifestCommittable

Modifier and Type	Method and Description
void	WrappedManifestCommittable.putManifestCommittable(Identifier identifier, ManifestCommittable manifestCommittable)
byte[]	ManifestCommittableSerializer.serialize(ManifestCommittable obj)

Uses of ManifestCommittable in org.apache.paimon.metastore

Methods in org.apache.paimon.metastore with parameters of type ManifestCommittable

Modifier and Type	Method and Description
void	AddPartitionCommitCallback.retry(ManifestCommittable committable)
void	TagPreviewCommitCallback.retry(ManifestCommittable committable)

Uses of ManifestCommittable in org.apache.paimon.operation

Methods in org.apache.paimon.operation that return types with arguments of type ManifestCommittable

Modifier and Type	Method and Description
List<ManifestCommittable>	FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committables)
List<ManifestCommittable>	FileStoreCommit.filterCommitted(List<ManifestCommittable> committables) Find out which committables need to be retried when recovering from the failure.

Methods in org.apache.paimon.operation with parameters of type ManifestCommittable

Modifier and Type	Method and Description
void	FileStoreCommitImpl.commit(ManifestCommittable committable, Map<String,String> properties)
void	FileStoreCommit.commit(ManifestCommittable committable, Map<String,String> properties) Commit from manifest committable.
void	FileStoreCommitImpl.commit(ManifestCommittable committable, Map<String,String> properties, boolean checkAppendFiles)
void	FileStoreCommit.commit(ManifestCommittable committable, Map<String,String> properties, boolean checkAppendFiles) Commit from manifest committable with checkAppendFiles.
void	FileStoreCommitImpl.overwrite(Map<String,String> partition, ManifestCommittable committable, Map<String,String> properties)
void	FileStoreCommit.overwrite(Map<String,String> partition, ManifestCommittable committable, Map<String,String> properties) Overwrite from manifest committable and partition.

Method parameters in org.apache.paimon.operation with type arguments of type ManifestCommittable

Modifier and Type	Method and Description
List<ManifestCommittable>	FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committables)
List<ManifestCommittable>	FileStoreCommit.filterCommitted(List<ManifestCommittable> committables) Find out which committables need to be retried when recovering from the failure.

Uses of ManifestCommittable in org.apache.paimon.table.sink

Methods in org.apache.paimon.table.sink with parameters of type ManifestCommittable

Modifier and Type	Method and Description
void	TableCommitImpl.commit(ManifestCommittable committable)
void	CommitCallback.retry(ManifestCommittable committable)

Method parameters in org.apache.paimon.table.sink with type arguments of type ManifestCommittable

Modifier and Type	Method and Description
void	TableCommitImpl.commitMultiple(List<ManifestCommittable> committables, boolean checkAppendFiles)
int	TableCommitImpl.filterAndCommitMultiple(List<ManifestCommittable> committables)
int	TableCommitImpl.filterAndCommitMultiple(List<ManifestCommittable> committables, boolean checkAppendFiles)