pyflink.datastream.functions.Partitioner

class Partitioner

Function to implement a custom partition assignment for keys.

Methods

close()
open(runtime_context)
partition(key, num_partitions)	Computes the partition for the given key.