public class IndexHashBatchToPartition extends Object implements SingleEmitAggregator.BatchToPartition
| Constructor and Description |
|---|
IndexHashBatchToPartition() |
public int partitionIndex(Object batchId, int numPartitions)
partitionIndex in interface SingleEmitAggregator.BatchToPartitionCopyright © 2021 The Apache Software Foundation. All rights reserved.