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

Methods

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

Method Detail

partitionIndex

int partitionIndex(Object batchId,
                 int numPartitions)