Interface SingleEmitAggregator.BatchToPartition

All Superinterfaces:
Serializable
All Known Implementing Classes:
GlobalBatchToPartition, IndexHashBatchToPartition
Enclosing class:
SingleEmitAggregator

public static interface SingleEmitAggregator.BatchToPartition extends Serializable
  • Method Summary

    Modifier and Type
    Method
    Description
    int
    partitionIndex(Object batchId, int numPartitions)
     
  • Method Details

    • partitionIndex

      int partitionIndex(Object batchId, int numPartitions)