org.apache.flink.streaming.connectors.kinesis

Interfaces

• KinesisShardAssigner

Classes

• FixedKinesisPartitioner
• FlinkDynamoDBStreamsConsumer
• FlinkKinesisConsumer
• FlinkKinesisProducer
• KinesisPartitioner
• RandomKinesisPartitioner

Exceptions

• FlinkKinesisException
• FlinkKinesisException.FlinkKinesisTimeoutException