@Internal public class KinesisStreamsConnectorOptionsUtils extends Object
AWSOptionUtils
, AsyncClientOptionsUtils
for handling each specified set of options.Modifier and Type | Class and Description |
---|---|
static class |
KinesisStreamsConnectorOptionsUtils.KinesisProducerOptionsMapper
Class for Mapping and validation of deprecated producer options.
|
Modifier and Type | Field and Description |
---|---|
static String |
KINESIS_CLIENT_PROPERTIES_KEY
Key for accessing kinesisAsyncClient properties.
|
Constructor and Description |
---|
KinesisStreamsConnectorOptionsUtils(Map<String,String> options,
ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
List<String> |
getNonValidatedPrefixes() |
Properties |
getValidatedSinkConfigurations() |
public static final String KINESIS_CLIENT_PROPERTIES_KEY
public KinesisStreamsConnectorOptionsUtils(Map<String,String> options, ReadableConfig tableOptions, RowType physicalType, List<String> partitionKeys, ClassLoader classLoader)
public Properties getValidatedSinkConfigurations()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.