raviv
08/11/2024, 7:55 AM@Public
@FunctionalInterface
public interface Partitioner<K> extends java.io.Serializable, Function {
/**
* Computes the partition for the given key.
*
* @param key The key.
* @param numPartitions The number of partitions to partition into.
* @return The partition index.
*/
int partition(K key, int numPartitions);
}
D. Draco O'Brien
08/11/2024, 9:40 AMD. Draco O'Brien
08/11/2024, 9:45 AMD. Draco O'Brien
08/11/2024, 9:48 AMraviv
08/11/2024, 9:51 AMD. Draco O'Brien
08/11/2024, 9:51 AMD. Draco O'Brien
08/11/2024, 9:55 AMD. Draco O'Brien
08/11/2024, 9:57 AMraviv
08/11/2024, 9:57 AMraviv
08/11/2024, 9:58 AMraviv
08/11/2024, 9:58 AMD. Draco O'Brien
08/11/2024, 9:59 AMraviv
08/11/2024, 10:00 AMD. Draco O'Brien
08/11/2024, 10:03 AMD. Draco O'Brien
08/11/2024, 10:05 AMD. Draco O'Brien
08/11/2024, 10:12 AMD. Draco O'Brien
08/11/2024, 10:18 AMD. Draco O'Brien
08/11/2024, 10:23 AMD. Draco O'Brien
08/11/2024, 10:28 AM