public class RowPartitionKeyExtractor extends Object implements PartitionKeyExtractor<InternalRow>
Constructor and Description |
---|
RowPartitionKeyExtractor(TableSchema schema) |
Modifier and Type | Method and Description |
---|---|
BinaryRow |
partition(InternalRow record) |
BinaryRow |
trimmedPrimaryKey(InternalRow record) |
public RowPartitionKeyExtractor(TableSchema schema)
public BinaryRow partition(InternalRow record)
partition
in interface PartitionKeyExtractor<InternalRow>
public BinaryRow trimmedPrimaryKey(InternalRow record)
trimmedPrimaryKey
in interface PartitionKeyExtractor<InternalRow>
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.