Package org.apache.storm.trident.fluent

Interface GlobalAggregationScheme<S extends IAggregatableStream>

All Known Implementing Classes:

GroupedStream

public interface GlobalAggregationScheme<S extends IAggregatableStream>

Method Summary

Modifier and Type	Method	Description
IAggregatableStream	aggPartition(S stream)
SingleEmitAggregator.BatchToPartition	singleEmitPartitioner()

Method Details

aggPartition

IAggregatableStream aggPartition(S stream)

singleEmitPartitioner

SingleEmitAggregator.BatchToPartition singleEmitPartitioner()