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 © 2019 The Apache Software Foundation. All rights reserved.