Uses of Interface
org.apache.paimon.table.sink.KeyAndBucketExtractor

Packages that use KeyAndBucketExtractor

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

Uses of KeyAndBucketExtractor in org.apache.paimon.flink.lookup

Classes in org.apache.paimon.flink.lookup that implement KeyAndBucketExtractor

Modifier and Type	Class and Description
class	FixedBucketFromPkExtractor Extractor to extract bucket from the primary key.

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

Classes in org.apache.paimon.flink.sink that implement KeyAndBucketExtractor

Modifier and Type	Class and Description
class	RowDataKeyAndBucketExtractor KeyAndBucketExtractor for RowData.

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

Classes in org.apache.paimon.flink.sink.cdc that implement KeyAndBucketExtractor

Modifier and Type	Class and Description
class	CdcRecordKeyAndBucketExtractor KeyAndBucketExtractor for CdcRecord.

Methods in org.apache.paimon.flink.sink.cdc that return KeyAndBucketExtractor

Modifier and Type	Method and Description
protected KeyAndBucketExtractor<CdcRecord>	CdcRecordChannelComputer.createExtractor()
protected abstract KeyAndBucketExtractor<T>	CdcFixedBucketChannelComputerBase.createExtractor()
protected abstract KeyAndBucketExtractor<T>	CdcDynamicBucketSinkBase.createExtractor(TableSchema schema)
protected KeyAndBucketExtractor<CdcRecord>	CdcDynamicBucketSink.createExtractor(TableSchema schema)

Uses of KeyAndBucketExtractor in org.apache.paimon.table.sink

Classes in org.apache.paimon.table.sink that implement KeyAndBucketExtractor

Modifier and Type	Class and Description
class	DynamicBucketRowKeyExtractor KeyAndBucketExtractor for InternalRow, just throws error when extract bucket from dynamic row.
class	FixedBucketRowKeyExtractor KeyAndBucketExtractor for InternalRow.
class	RowKeyExtractor KeyAndBucketExtractor for InternalRow.
class	UnawareBucketRowKeyExtractor Unaware bucket table put all records into bucket 0 (for comparability with old design).

Constructors in org.apache.paimon.table.sink with parameters of type KeyAndBucketExtractor

Constructor and Description
TableWriteImpl(RowType rowType, FileStoreWrite<T> write, KeyAndBucketExtractor<InternalRow> keyAndBucketExtractor, TableWriteImpl.RecordExtractor<T> recordExtractor, RowKindGenerator rowKindGenerator, boolean ignoreDelete)