Uses of Interface
org.apache.storm.trident.operation.impl.SingleEmitAggregator.BatchToPartition
Packages that use SingleEmitAggregator.BatchToPartition
-
Uses of SingleEmitAggregator.BatchToPartition in org.apache.storm.trident.fluent
Methods in org.apache.storm.trident.fluent that return SingleEmitAggregator.BatchToPartitionModifier and TypeMethodDescriptionGlobalAggregationScheme.singleEmitPartitioner()
GroupedStream.singleEmitPartitioner()
-
Uses of SingleEmitAggregator.BatchToPartition in org.apache.storm.trident.operation.impl
Classes in org.apache.storm.trident.operation.impl that implement SingleEmitAggregator.BatchToPartitionConstructors in org.apache.storm.trident.operation.impl with parameters of type SingleEmitAggregator.BatchToPartitionModifierConstructorDescriptionSingleEmitAggregator
(Aggregator agg, SingleEmitAggregator.BatchToPartition batchToPartition)