@Internal public final class RowDataFieldsKinesisPartitioner extends KinesisPartitioner<RowData>
KinesisPartitioner
of RowData
elements that constructs the partition key from a
list of field names.
The key is constructed by concatenating the string representations of a list of fields projected from an input element. A fixed prefix can be optionally configured in order to speed up the key construction process.
Resulting partition key values are trimmed to the maximum length allowed by Kinesis.
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_DELIMITER
Default delimiter for
delimiter . |
static int |
MAX_PARTITION_KEY_LENGTH
Allowed maximum length limit of a partition key.
|
Constructor and Description |
---|
RowDataFieldsKinesisPartitioner(RowType physicalType,
List<String> partitionKeys) |
RowDataFieldsKinesisPartitioner(RowType physicalType,
List<String> partitionKeys,
String delimiter) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
getPartitionId(RowData element)
Return a partition id based on the input.
|
int |
hashCode() |
void |
setStaticFields(Map<String,String> staticFields)
Update the fixed partition key prefix.
|
getExplicitHashKey, initialize
public static final int MAX_PARTITION_KEY_LENGTH
public RowDataFieldsKinesisPartitioner(RowType physicalType, List<String> partitionKeys)
public String getPartitionId(RowData element)
KinesisPartitioner
getPartitionId
in class KinesisPartitioner<RowData>
element
- Element to partitionpublic void setStaticFields(Map<String,String> staticFields)
staticFields
- An association of (field name, field value) pairs to be used as static
partition key prefix.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.