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

Packages that use FlinkWriteSink

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

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

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

Modifier and Type	Class and Description
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	RewriteFileIndexSink File index sink for RewriteFileIndexProcedure.
class	RowDynamicBucketSink Sink for dynamic bucket table.
class	RowUnawareBucketSink An UnawareBucketSink which handles InternalRow.
class	UnawareBucketSink<T> Sink for unaware-bucket table.

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

Subclasses of FlinkWriteSink 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 FlinkWriteSink in org.apache.paimon.flink.sink.index

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

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