public class CdcRecordKeyAndBucketExtractor extends Object implements KeyAndBucketExtractor<CdcRecord>
Constructor and Description |
---|
CdcRecordKeyAndBucketExtractor(TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
int |
bucket() |
BinaryRow |
logPrimaryKey() |
BinaryRow |
partition() |
void |
setRecord(CdcRecord record) |
BinaryRow |
trimmedPrimaryKey() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucket, bucketKeyHashCode
public CdcRecordKeyAndBucketExtractor(TableSchema schema)
public void setRecord(CdcRecord record)
setRecord
in interface KeyAndBucketExtractor<CdcRecord>
public BinaryRow partition()
partition
in interface KeyAndBucketExtractor<CdcRecord>
public int bucket()
bucket
in interface KeyAndBucketExtractor<CdcRecord>
public BinaryRow trimmedPrimaryKey()
trimmedPrimaryKey
in interface KeyAndBucketExtractor<CdcRecord>
public BinaryRow logPrimaryKey()
logPrimaryKey
in interface KeyAndBucketExtractor<CdcRecord>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.