Uses of Package
org.apache.paimon.flink.sink

Packages that use org.apache.paimon.flink.sink

Package	Description
org.apache.paimon.flink
org.apache.paimon.flink.compact
org.apache.paimon.flink.compact.changelog
org.apache.paimon.flink.kafka
org.apache.paimon.flink.log
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.sink.index
org.apache.paimon.flink.sink.partition

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink

Class and Description
StoreSinkWrite Helper class of PrepareCommitOperator for different types of paimon sinks.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.compact

Class and Description
Committable Committable produced by PrepareCommitOperator.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.compact.changelog

Class and Description
Committable Committable produced by PrepareCommitOperator.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.kafka

Class and Description
LogSinkFunction Log SinkFunction with LogSinkFunction.WriteCallback.
LogSinkFunction.WriteCallback A callback interface that the user can implement to know the offset of the bucket when the request is complete.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.log

Class and Description
LogSinkFunction Log SinkFunction with LogSinkFunction.WriteCallback.
LogSinkFunction.WriteCallback A callback interface that the user can implement to know the offset of the bucket when the request is complete.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.sink

Class and Description
AppendCompactWorkerOperator An abstract Operator to execute UnawareAppendCompactionTask passed from BucketUnawareCompactSource for compacting table.
Committable Committable produced by PrepareCommitOperator.
Committable.Kind Kind of the produced Committable.
CommittableStateManager Helper interface for CommitterOperator.
Committer The Committer is responsible for creating and committing an aggregated committable, which we call committable (see Committer.combine(long, long, java.util.List<CommitT>)).
Committer.Context Context to create Committer.
Committer.Factory Factory to create Committer.
CommitterMetrics Flink metrics for Committer.
CommitterOperator Operator to commit Committables for each snapshot.
CompactorSinkBuilder Builder for CompactorSink.
DynamicBucketSink Sink for dynamic bucket table.
FlinkSink Abstract sink of paimon.
FlinkSinkBuilder DataStream API for building Flink Sink.
FlinkTableSinkBase Table sink to create sink.
FlinkWriteSink A FlinkSink to write records.
HashBucketAssignerOperator Assign bucket for the input record, output record with bucket.
LogFlinkSinkBuilder A special version FlinkSinkBuilder with log sink.
LogOffsetCommittable Log offset committable for a bucket.
LogSinkFunction Log SinkFunction with LogSinkFunction.WriteCallback.
LogSinkFunction.WriteCallback A callback interface that the user can implement to know the offset of the bucket when the request is complete.
MultiTableCommittable MultiTableCommittable produced by PrepareCommitOperator.
MultiTableCommittable.Kind Kind of the produced Committable.
PrepareCommitOperator Prepare commit operator to emit Committables.
RowDynamicBucketSink Sink for dynamic bucket table.
StoreSinkWrite Helper class of PrepareCommitOperator for different types of paimon sinks.
StoreSinkWrite.Provider Provider of StoreSinkWrite.
StoreSinkWriteImpl Default implementation of StoreSinkWrite.
StoreSinkWriteState States for StoreSinkWrites.
StoreSinkWriteState.StateValue A state value for StoreSinkWrite.
StoreSinkWriteState.StateValueFilter Given the table name, partition and bucket of a StoreSinkWriteState.StateValue in a union list state, decide whether to keep this StoreSinkWriteState.StateValue in this subtask.
SupportsRowLevelOperationFlinkTableSink Flink table sink that supports row level update and delete.
TableWriteOperator An abstract class for table write operator.
UnawareBucketSink Sink for unaware-bucket table.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.sink.cdc

Class and Description
Committable Committable produced by PrepareCommitOperator.
CommittableStateManager Helper interface for CommitterOperator.
Committer.Factory Factory to create Committer.
DynamicBucketSink Sink for dynamic bucket table.
FlinkSink Abstract sink of paimon.
FlinkWriteSink A FlinkSink to write records.
MultiTableCommittable MultiTableCommittable produced by PrepareCommitOperator.
PrepareCommitOperator Prepare commit operator to emit Committables.
StoreSinkWrite Helper class of PrepareCommitOperator for different types of paimon sinks.
StoreSinkWrite.Provider Provider of StoreSinkWrite.
StoreSinkWrite.WithWriteBufferProvider Provider of StoreSinkWrite that uses given write buffer.
TableWriteOperator An abstract class for table write operator.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.sink.index

Class and Description
Committable Committable produced by PrepareCommitOperator.
FlinkSink Abstract sink of paimon.
FlinkWriteSink A FlinkSink to write records.
StoreSinkWrite.Provider Provider of StoreSinkWrite.

Classes in org.apache.paimon.flink.sink used by org.apache.paimon.flink.sink.partition

Class and Description
Committer.Context Context to create Committer.