public abstract class RowKeyExtractor extends Object implements KeyAndBucketExtractor<InternalRow>
Modifier and Type | Field and Description |
---|---|
protected InternalRow |
record |
Constructor and Description |
---|
RowKeyExtractor(TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
logPrimaryKey() |
BinaryRow |
partition() |
void |
setRecord(InternalRow record) |
BinaryRow |
trimmedPrimaryKey() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucket, bucket, bucketKeyHashCode
protected InternalRow record
public RowKeyExtractor(TableSchema schema)
public void setRecord(InternalRow record)
setRecord
in interface KeyAndBucketExtractor<InternalRow>
public BinaryRow partition()
partition
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.