@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(CatalogTable table) |
RowDataFieldsKinesisPartitioner(CatalogTable table,
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(CatalogTable table)
public RowDataFieldsKinesisPartitioner(CatalogTable table, String delimiter)
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–2021 The Apache Software Foundation. All rights reserved.