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

Packages that use FlinkSink

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

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

Subclasses of FlinkSink in org.apache.paimon.flink.sink

Modifier and Type	Class and Description
class	CompactorSink FlinkSink for dedicated compact jobs.
class	DynamicBucketCompactSink This class is only used for generate compact sink topology for dynamic bucket table.
class	DynamicBucketSink<T> Sink for dynamic bucket table.
class	FixedBucketSink FlinkSink for writing records into fixed bucket Paimon table.
class	FlinkWriteSink<T> A FlinkSink to write records.
class	RewriteFileIndexSink File index sink for RewriteFileIndexProcedure.
class	RowDynamicBucketSink Sink for dynamic bucket table.
class	RowUnawareBucketSink An UnawareBucketSink which handles InternalRow.
class	UnawareBucketCompactionSink Compaction Sink for unaware-bucket table.
class	UnawareBucketSink<T> Sink for unaware-bucket table.

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

Subclasses of FlinkSink in org.apache.paimon.flink.sink.cdc

Modifier and Type	Class and Description
class	CdcDynamicBucketSink CdcDynamicBucketSinkBase for CdcRecord.
class	CdcDynamicBucketSinkBase<T> CDC sink for dynamic bucket table.
class	CdcFixedBucketSink A FlinkSink for fixed-bucket table which accepts CdcRecord and waits for a schema change if necessary.
class	CdcUnawareBucketSink CDC Sink for unaware bucket table.

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

Subclasses of FlinkSink in org.apache.paimon.flink.sink.index

Modifier and Type	Class and Description
class	GlobalDynamicBucketSink Sink for global dynamic bucket table.