org.apache.paimon.table.sink

Class PostponeBucketRowKeyExtractor

java.lang.Object

org.apache.paimon.table.sink.RowKeyExtractor

org.apache.paimon.table.sink.PostponeBucketRowKeyExtractor

All Implemented Interfaces:

KeyAndBucketExtractor<InternalRow>

public class PostponeBucketRowKeyExtractor
extends RowKeyExtractor

RowKeyExtractor for postpone bucket tables. The bucket is always BucketMode.POSTPONE_BUCKET.

Field Summary

Fields inherited from class org.apache.paimon.table.sink.RowKeyExtractor

record

Fields inherited from interface org.apache.paimon.table.sink.KeyAndBucketExtractor

LOG

Constructor Summary

Constructors

Constructor and Description
PostponeBucketRowKeyExtractor(TableSchema schema)

Method Summary

Modifier and Type	Method and Description
int	bucket()

Methods inherited from class org.apache.paimon.table.sink.RowKeyExtractor

logPrimaryKey, partition, setRecord, trimmedPrimaryKey

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.sink.KeyAndBucketExtractor

bucket, bucketKeyHashCode

Constructor Detail

PostponeBucketRowKeyExtractor

public PostponeBucketRowKeyExtractor(TableSchema schema)

Method Detail

bucket

public int bucket()