@PublicEvolving public class KinesisConsumerOptionsUtil extends AWSOptionUtils
Modifier and Type | Field and Description |
---|---|
static String |
CONSUMER_PREFIX
Prefix for properties defined in {
org.apache.flink.streaming.connectors.kinesis.config.ConsumerConfigConstants} that are
delegated to { org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer}.
|
AWS_PROPERTIES_PREFIX
Constructor and Description |
---|
KinesisConsumerOptionsUtil(Map<String,String> resolvedOptions,
String stream) |
Modifier and Type | Method and Description |
---|---|
List<String> |
getNonValidatedPrefixes() |
Map<String,String> |
getProcessedResolvedOptions()
Returns table options after processing keys and values to specific handler formats.
|
Properties |
getValidatedConfigurations() |
public static final String CONSUMER_PREFIX
public Map<String,String> getProcessedResolvedOptions()
TableOptionsUtils
getProcessedResolvedOptions
in interface TableOptionsUtils
getProcessedResolvedOptions
in class AWSOptionUtils
public List<String> getNonValidatedPrefixes()
getNonValidatedPrefixes
in interface TableOptionsUtils
getNonValidatedPrefixes
in class AWSOptionUtils
public Properties getValidatedConfigurations()
getValidatedConfigurations
in interface ConfigurationValidator
getValidatedConfigurations
in class AWSOptionUtils
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.