pyflink.datastream.connectors.kinesis.PartitionKeyGenerator

class PartitionKeyGenerator(j_partition_key_generator)

This is a generator convert from an input element to the partition key, a string.

Methods

fixed()	A partitioner ensuring that each internal Flink partition ends up in the same Kinesis partition.
random()	A PartitionKeyGenerator that maps an arbitrary input element to a random partition ID.