Modifier and Type | Field and Description |
---|---|
static String |
AWS_PROPERTIES_PREFIX
Prefix for properties defined in
AWSConfigConstants that are delegated
to FlinkKinesisConsumer and FlinkKinesisProducer . |
static String |
CONSUMER_PREFIX
Prefix for properties defined in
ConsumerConfigConstants that are
delegated to FlinkKinesisConsumer . |
static String[] |
NON_VALIDATED_PREFIXES
Prefixes of properties that are validated by downstream components and should not be
validated by the Table API infrastructure.
|
static String |
PRODUCER_PREFIX
Prefix for properties defined in
KinesisProducerConfiguration that are delegated to
FlinkKinesisConsumer . |
static ConfigOption<String> |
SINK_PARTITIONER |
static ConfigOption<String> |
SINK_PARTITIONER_FIELD_DELIMITER |
static String |
SINK_PARTITIONER_VALUE_FIXED |
static String |
SINK_PARTITIONER_VALUE_RANDOM |
static ConfigOption<String> |
STREAM |
static Set<String> |
TABLE_LEVEL_OPTIONS
Options handled and validated by the table-level layer.
|
Modifier and Type | Method and Description |
---|---|
static Properties |
getConsumerProperties(Map<String,String> tableOptions)
Derive properties to be passed to the
FlinkKinesisConsumer . |
static KinesisPartitioner<RowData> |
getKinesisPartitioner(ReadableConfig tableOptions,
CatalogTable targetTable,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
static Properties |
getProducerProperties(Map<String,String> tableOptions)
Derive properties to be passed to the
FlinkKinesisProducer . |
public static final String AWS_PROPERTIES_PREFIX
AWSConfigConstants
that are delegated
to FlinkKinesisConsumer
and FlinkKinesisProducer
.public static final String CONSUMER_PREFIX
ConsumerConfigConstants
that are
delegated to FlinkKinesisConsumer
.public static final String PRODUCER_PREFIX
KinesisProducerConfiguration
that are delegated to
FlinkKinesisConsumer
.public static final String[] NON_VALIDATED_PREFIXES
public static final ConfigOption<String> STREAM
public static final ConfigOption<String> SINK_PARTITIONER
public static final ConfigOption<String> SINK_PARTITIONER_FIELD_DELIMITER
public static final String SINK_PARTITIONER_VALUE_FIXED
public static final String SINK_PARTITIONER_VALUE_RANDOM
public static Properties getConsumerProperties(Map<String,String> tableOptions)
FlinkKinesisConsumer
.public static Properties getProducerProperties(Map<String,String> tableOptions)
FlinkKinesisProducer
.public static KinesisPartitioner<RowData> getKinesisPartitioner(ReadableConfig tableOptions, CatalogTable targetTable, ClassLoader classLoader)
targetTable
based on the currently set
tableOptions
.
The following rules are applied with decreasing precedence order.
targetTable
is partitioned, return a RowDataKinesisPartitioner
.
RandomKinesisPartitioner
.
tableOptions
- A read-only set of config options that determines the partitioner type.targetTable
- A catalog version of the table backing the partitioner.classLoader
- A ClassLoader
to use for loading user-defined partitioner classes.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.