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

Packages that use WrappedManifestCommittable

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc

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

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

Modifier and Type	Method and Description
WrappedManifestCommittable	StoreMultiCommitter.combine(long checkpointId, long watermark, List<MultiTableCommittable> committables)
WrappedManifestCommittable	StoreMultiCommitter.combine(long checkpointId, long watermark, WrappedManifestCommittable wrappedManifestCommittable, List<MultiTableCommittable> committables)
WrappedManifestCommittable	WrappedManifestCommittableSerializer.deserialize(int version, byte[] serialized)

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

Modifier and Type	Method and Description
protected CommittableStateManager<WrappedManifestCommittable>	CombinedTableCompactorSink.createCommittableStateManager()
protected Committer.Factory<MultiTableCommittable,WrappedManifestCommittable>	CombinedTableCompactorSink.createCommitterFactory(boolean isStreaming)

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

Modifier and Type	Method and Description
WrappedManifestCommittable	StoreMultiCommitter.combine(long checkpointId, long watermark, WrappedManifestCommittable wrappedManifestCommittable, List<MultiTableCommittable> committables)
byte[]	WrappedManifestCommittableSerializer.serialize(WrappedManifestCommittable wrapped)

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

Modifier and Type	Method and Description
void	StoreMultiCommitter.commit(List<WrappedManifestCommittable> committables)
int	StoreMultiCommitter.filterAndCommit(List<WrappedManifestCommittable> globalCommittables, boolean checkAppendFiles)

Uses of WrappedManifestCommittable in org.apache.paimon.flink.sink.cdc

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

Modifier and Type	Method and Description
protected CommittableStateManager<WrappedManifestCommittable>	FlinkCdcMultiTableSink.createCommittableStateManager()
protected Committer.Factory<MultiTableCommittable,WrappedManifestCommittable>	FlinkCdcMultiTableSink.createCommitterFactory()