Package | Description |
---|---|
org.apache.flink.connector.kinesis.sink | |
org.apache.flink.connector.kinesis.table | |
org.apache.flink.streaming.connectors.kinesis |
Modifier and Type | Method and Description |
---|---|
KinesisStreamsSinkElementConverter.Builder<InputT> |
KinesisStreamsSinkElementConverter.Builder.setPartitionKeyGenerator(PartitionKeyGenerator<InputT> partitionKeyGenerator) |
KinesisStreamsSinkBuilder<InputT> |
KinesisStreamsSinkBuilder.setPartitionKeyGenerator(PartitionKeyGenerator<InputT> partitionKeyGenerator) |
Modifier and Type | Class and Description |
---|---|
class |
FixedKinesisPartitionKeyGenerator<T>
A partitioner ensuring that each internal Flink partition ends up in the same Kinesis partition.
|
class |
RandomKinesisPartitionKeyGenerator<T>
A
PartitionKeyGenerator that maps an arbitrary input element to a random
partition ID. |
class |
RowDataFieldsKinesisPartitionKeyGenerator
A
PartitionKeyGenerator of RowData elements that constructs the partition key
from a list of field names. |
Modifier and Type | Method and Description |
---|---|
static PartitionKeyGenerator<RowData> |
KinesisPartitionKeyGeneratorFactory.getKinesisPartitioner(ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
Modifier and Type | Method and Description |
---|---|
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setPartitioner(PartitionKeyGenerator<RowData> partitioner) |
Constructor and Description |
---|
KinesisDynamicSink(Integer maxBatchSize,
Integer maxInFlightRequests,
Integer maxBufferedRequests,
Long maxBufferSizeInBytes,
Long maxTimeInBufferMS,
Boolean failOnError,
DataType consumedDataType,
String stream,
Properties kinesisClientProperties,
EncodingFormat<SerializationSchema<RowData>> encodingFormat,
PartitionKeyGenerator<RowData> partitioner) |
Modifier and Type | Class and Description |
---|---|
class |
KinesisPartitioner<T>
An interface for partitioning records.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.