Package | Description |
---|---|
org.apache.flink.streaming.connectors.kinesis | |
org.apache.flink.streaming.connectors.kinesis.internals |
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.
|
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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.