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