Package org.apache.storm.trident.operation.impl

# 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)