storm.trident.operation.impl
Interface SingleEmitAggregator.BatchToPartition

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

public static interface SingleEmitAggregator.BatchToPartition
extends java.io.Serializable


Method Summary
 int partitionIndex(java.lang.Object batchId, int numPartitions)
           
 

Method Detail

partitionIndex

int partitionIndex(java.lang.Object batchId,
                   int numPartitions)