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