@Internal public class KinesisPartitionKeyGeneratorFactory extends Object
PartitionKeyGenerator
.Modifier and Type | Field and Description |
---|---|
static String |
SINK_PARTITIONER_VALUE_FIXED |
static String |
SINK_PARTITIONER_VALUE_RANDOM |
Constructor and Description |
---|
KinesisPartitionKeyGeneratorFactory() |
Modifier and Type | Method and Description |
---|---|
static PartitionKeyGenerator<RowData> |
getKinesisPartitioner(ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
public static final String SINK_PARTITIONER_VALUE_FIXED
public static final String SINK_PARTITIONER_VALUE_RANDOM
public static PartitionKeyGenerator<RowData> getKinesisPartitioner(ReadableConfig tableOptions, RowType physicalType, List<String> partitionKeys, ClassLoader classLoader)
targetTable
based on the currently set
tableOptions
.
The following rules are applied with decreasing precedence order.
targetTable
is partitioned, return a RowDataKinesisPartitioner
.
RandomKinesisPartitionKeyGenerator
.
tableOptions
- A read-only set of config options that determines the partitioner type.physicalType
- Physical type for partitioning.partitionKeys
- Partitioning keys in physical type.classLoader
- A ClassLoader
to use for loading user-defined partitioner classes.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.