Uses of Class
org.apache.paimon.flink.sink.Committable

Packages that use Committable

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

Uses of Committable in org.apache.paimon.flink.compact

Methods in org.apache.paimon.flink.compact that return types with arguments of type Committable

Modifier and Type	Method and Description
List<Committable>	UnawareBucketCompactor.prepareCommit(boolean waitCompaction, long checkpointId)

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

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

Modifier and Type	Method and Description
Committable	CommittableSerializer.deserialize(int committableVersion, byte[] bytes)
Committable	MultiTableCommittableSerializer.deserializeCommittable(int committableVersion, byte[] bytes)

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

Modifier and Type	Method and Description
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()
org.apache.flink.api.common.typeutils.TypeSerializer<Committable>	CommittableTypeInfo.createSerializer(org.apache.flink.api.common.ExecutionConfig config)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	FixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable>	UnawareBucketCompactionSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable>	RewriteFileIndexSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	RowDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperator<T,Committable>	FlinkSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable>	CompactorSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable>	RowUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
org.apache.flink.streaming.api.datastream.DataStream<Committable>	UnawareBucketSink.doWrite(org.apache.flink.streaming.api.datastream.DataStream<T> input, String initialCommitUser, Integer parallelism)
org.apache.flink.streaming.api.datastream.DataStream<Committable>	FlinkSink.doWrite(org.apache.flink.streaming.api.datastream.DataStream<T> input, String commitUser, Integer parallelism)
Class<Committable>	CommittableTypeInfo.getTypeClass()
Map<Long,List<Committable>>	StoreCommitter.groupByCheckpoint(Collection<Committable> committables)
protected List<Committable>	AppendCompactWorkerOperator.prepareCommit(boolean waitCompaction, long checkpointId)
List<Committable>	StoreSinkWrite.prepareCommit(boolean waitCompaction, long checkpointId)
List<Committable>	GlobalFullCompactionSinkWrite.prepareCommit(boolean waitCompaction, long checkpointId)
protected List<Committable>	TableWriteOperator.prepareCommit(boolean waitCompaction, long checkpointId)
protected List<Committable>	RowDataStoreWriteOperator.prepareCommit(boolean waitCompaction, long checkpointId)
protected List<Committable>	StoreCompactOperator.prepareCommit(boolean waitCompaction, long checkpointId)
List<Committable>	StoreSinkWriteImpl.prepareCommit(boolean waitCompaction, long checkpointId)

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

Modifier and Type	Method and Description
static MultiTableCommittable	MultiTableCommittable.fromCommittable(Identifier id, Committable committable)
byte[]	CommittableSerializer.serialize(Committable committable)

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

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)
protected org.apache.flink.streaming.api.datastream.DataStreamSink<?>	FlinkSink.doCommit(org.apache.flink.streaming.api.datastream.DataStream<Committable> written, String commitUser)
Map<Long,List<Committable>>	StoreCommitter.groupByCheckpoint(Collection<Committable> committables)
void	AppendBypassCompactWorkerOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<org.apache.flink.types.Either<Committable,UnawareAppendCompactionTask>> element)
void	RowDataStoreWriteOperator.setup(org.apache.flink.streaming.runtime.tasks.StreamTask<?,?> containingTask, org.apache.flink.streaming.api.graph.StreamConfig config, org.apache.flink.streaming.api.operators.Output<org.apache.flink.streaming.runtime.streamrecord.StreamRecord<Committable>> output)

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

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable>	CdcFixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable>	CdcUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable>	CdcDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)

Uses of Committable in org.apache.paimon.flink.sink.index

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

Modifier and Type	Method and Description
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable>	GlobalDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider, String commitUser)