Package org.apache.storm.trident.fluent
Class ChainedAggregatorDeclarer
java.lang.Object
org.apache.storm.trident.fluent.ChainedAggregatorDeclarer
- All Implemented Interfaces:
- ChainedFullAggregatorDeclarer,- ChainedPartitionAggregatorDeclarer,- IChainedAggregatorDeclarer
public class ChainedAggregatorDeclarer
extends Object
implements ChainedFullAggregatorDeclarer, ChainedPartitionAggregatorDeclarer
- 
Nested Class SummaryNested Classes
- 
Constructor SummaryConstructorsConstructorDescriptionChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme) 
- 
Method SummaryModifier and TypeMethodDescriptionaggregate(Aggregator agg, Fields functionFields) aggregate(CombinerAggregator agg, Fields functionFields) aggregate(ReducerAggregator agg, Fields functionFields) aggregate(Fields inputFields, Aggregator agg, Fields functionFields) aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) chainEnd()partitionAggregate(Aggregator agg, Fields functionFields) partitionAggregate(CombinerAggregator agg, Fields functionFields) partitionAggregate(ReducerAggregator agg, Fields functionFields) partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) 
- 
Constructor Details- 
ChainedAggregatorDeclarer
 
- 
- 
Method Details- 
chainEnd- Specified by:
- chainEndin interface- IChainedAggregatorDeclarer
 
- 
partitionAggregate- Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
partitionAggregatepublic ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) - Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
partitionAggregatepublic ChainedPartitionAggregatorDeclarer partitionAggregate(CombinerAggregator agg, Fields functionFields) - Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
partitionAggregatepublic ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) - Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
partitionAggregatepublic ChainedPartitionAggregatorDeclarer partitionAggregate(ReducerAggregator agg, Fields functionFields) - Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
partitionAggregatepublic ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) - Specified by:
- partitionAggregatein interface- ChainedPartitionAggregatorDeclarer
 
- 
aggregate- Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
- 
aggregatepublic ChainedFullAggregatorDeclarer aggregate(Fields inputFields, Aggregator agg, Fields functionFields) - Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
- 
aggregate- Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
- 
aggregatepublic ChainedFullAggregatorDeclarer aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) - Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
- 
aggregate- Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
- 
aggregatepublic ChainedFullAggregatorDeclarer aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) - Specified by:
- aggregatein interface- ChainedFullAggregatorDeclarer
 
 
-