org.apache.flink.connector.kinesis.table.util

Class KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper

java.lang.Object

org.apache.flink.connector.kinesis.table.util.KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper

Enclosing class:

KinesisStreamsConnectorOptionsUtils

@Internal
public static class KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper
extends Object

Class for Mapping and validation of deprecated producer options.

Field Summary

Fields

Modifier and Type	Field and Description
static String	KINESIS_PRODUCER_PREFIX prefix for deprecated producer options fallback keys.

Constructor Summary

Constructors

Constructor and Description
KinesisProducerOptionsMapper(Map<String,String> allOptions)
KinesisProducerOptionsMapper(ReadableConfig tableOptions, Map<String,String> resolvedOptions)

Method Summary

Modifier and Type	Method and Description
static Set<ConfigOption<?>>	addDeprecatedKeys(Set<ConfigOption<?>> tableOptions)
Map<String,String>	mapDeprecatedClientOptions()
ReadableConfig	mapDeprecatedTableOptions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KINESIS_PRODUCER_PREFIX

public static final String KINESIS_PRODUCER_PREFIX

prefix for deprecated producer options fallback keys.

See Also:

Constant Field Values

Constructor Detail

KinesisProducerOptionsMapper

public KinesisProducerOptionsMapper(ReadableConfig tableOptions,
                                    Map<String,String> resolvedOptions)

KinesisProducerOptionsMapper

@VisibleForTesting
public KinesisProducerOptionsMapper(Map<String,String> allOptions)

Method Detail

mapDeprecatedClientOptions

public Map<String,String> mapDeprecatedClientOptions()

mapDeprecatedTableOptions

public ReadableConfig mapDeprecatedTableOptions()

addDeprecatedKeys

public static Set<ConfigOption<?>> addDeprecatedKeys(Set<ConfigOption<?>> tableOptions)