pyflink.datastream.functions.Partitioner# class Partitioner[source]# 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.