Class | Description |
---|---|
FixedKinesisPartitionKeyGenerator<T> |
A partitioner ensuring that each internal Flink partition ends up in the same Kinesis partition.
|
KinesisConnectorOptions |
Options for the Kinesis connector.
|
KinesisDynamicSink |
Kinesis backed
AsyncDynamicTableSink . |
KinesisDynamicSink.KinesisDynamicTableSinkBuilder |
Builder class for
KinesisDynamicSink . |
KinesisDynamicTableSinkFactory |
Factory for creating
KinesisDynamicSink . |
KinesisPartitionKeyGeneratorFactory |
Factory Class for
PartitionKeyGenerator . |
RandomKinesisPartitionKeyGenerator<T> |
A
PartitionKeyGenerator that maps an arbitrary input element to a random
partition ID. |
RowDataFieldsKinesisPartitionKeyGenerator |
A
PartitionKeyGenerator of RowData elements that constructs the partition key
from a list of field names. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.