Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis | |
org.apache.flink.streaming.connectors.kinesis.table |
Modifier and Type | Class and Description |
---|---|
class |
FixedKinesisPartitioner<T>
A partitioner ensuring that each internal Flink partition ends up in the same Kinesis partition.
|
class |
RandomKinesisPartitioner<T>
A
KinesisPartitioner that maps an arbitrary input element to a random partition
ID. |
Modifier and Type | Method and Description |
---|---|
void |
FlinkKinesisProducer.setCustomPartitioner(KinesisPartitioner<OUT> partitioner) |
Modifier and Type | Class and Description |
---|---|
class |
RowDataFieldsKinesisPartitioner
A
KinesisPartitioner of RowData elements that constructs the partition key from a
list of field names. |
Modifier and Type | Method and Description |
---|---|
static KinesisPartitioner<RowData> |
KinesisOptions.getKinesisPartitioner(ReadableConfig tableOptions,
RowType physicalType,
List<String> partitionKeys,
ClassLoader classLoader)
Constructs the kinesis partitioner for a
targetTable based on the currently set
tableOptions . |
Constructor and Description |
---|
KinesisDynamicSink(DataType consumedDataType,
String stream,
Properties producerProperties,
EncodingFormat<SerializationSchema<RowData>> encodingFormat,
KinesisPartitioner<RowData> partitioner) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.