T
- The type of the partitioned data.public static class SplitDataProperties.SourcePartitionerMarker<T> extends Object implements Partitioner<T>
Constructor and Description |
---|
SourcePartitionerMarker(String partitionMarker) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
partition(T key,
int numPartitions)
Computes the partition for the given key.
|
public SourcePartitionerMarker(String partitionMarker)
public int partition(T key, int numPartitions)
Partitioner
partition
in interface Partitioner<T>
key
- The key.numPartitions
- The number of partitions to partition into.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.