public static interface SingleEmitAggregator.BatchToPartition extends Serializable
| Modifier and Type | Method and Description |
|---|---|
int |
partitionIndex(Object batchId,
int numPartitions) |
int partitionIndex(Object batchId, int numPartitions)
Copyright © 2021 The Apache Software Foundation. All rights reserved.