pyflink.datastream.connectors.pulsar.RangeGenerator

class RangeGenerator(j_range_generator)

A generator for generating the TopicRange for given topic. It was used for pulsar’s SubscriptionType#Key_Shared mode. TopicRange would be used in KeySharedPolicy for different pulsar source readers.

If you implement this interface, make sure that each TopicRange would be assigned to a specified source reader. Since flink parallelism is provided, make sure the pulsar message key’s hashcode is evenly distributed among these topic ranges.

Methods

fixed_key([support_null_key, keys, ...])	Pulsar didn't expose the key hash range method.
full()	Default implementation for SubscriptionType#Shared, SubscriptionType#Failover and SubscriptionType#Exclusive subscription.