pyflink.datastream.connectors.kinesis.KinesisShardAssigner

class KinesisShardAssigner(j_kinesis_shard_assigner)

Utility to map Kinesis shards to Flink subtask indices. Users can provide a Java KinesisShardAssigner in Python if they want to provide custom shared assigner.

Methods

default_shard_assigner()	A Default KinesisShardAssigner that maps Kinesis shard hash-key ranges to Flink subtasks.
uniform_shard_assigner()	A KinesisShardAssigner that maps Kinesis shard hash-key ranges to Flink subtasks.