storm.trident.fluent

Interface GlobalAggregationScheme<S extends IAggregatableStream>

All Known Implementing Classes:

GroupedStream

public interface GlobalAggregationScheme<S extends IAggregatableStream>

Method Summary

Methods

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

Method Detail

aggPartition

IAggregatableStream aggPartition(S stream)

singleEmitPartitioner

SingleEmitAggregator.BatchToPartition singleEmitPartitioner()