Class and Description |
---|
FlinkKinesisConsumer
The Flink Kinesis Consumer is an exactly-once parallel streaming data source that subscribes to
multiple AWS Kinesis streams within the same AWS service region, and can handle resharding of
streams.
|
FlinkKinesisException
A
RuntimeException wrapper indicating the exception was thrown from this connector. |
KinesisPartitioner
An interface for partitioning records.
|
KinesisShardAssigner
Utility to map Kinesis shards to Flink subtask indices.
|
Class and Description |
---|
KinesisShardAssigner
Utility to map Kinesis shards to Flink subtask indices.
|
Class and Description |
---|
FlinkKinesisException
A
RuntimeException wrapper indicating the exception was thrown from this connector. |
KinesisShardAssigner
Utility to map Kinesis shards to Flink subtask indices.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.