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 Summary
Nested Classes -
Constructor Summary
ConstructorsConstructorDescriptionChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme) -
Method Summary
Modifier 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 interfaceIChainedAggregatorDeclarer
-
partitionAggregate
- Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
partitionAggregate
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) - Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
partitionAggregate
public ChainedPartitionAggregatorDeclarer partitionAggregate(CombinerAggregator agg, Fields functionFields) - Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
partitionAggregate
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) - Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
partitionAggregate
public ChainedPartitionAggregatorDeclarer partitionAggregate(ReducerAggregator agg, Fields functionFields) - Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
partitionAggregate
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) - Specified by:
partitionAggregatein interfaceChainedPartitionAggregatorDeclarer
-
aggregate
- Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-
aggregate
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, Aggregator agg, Fields functionFields) - Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-
aggregate
- Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-
aggregate
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) - Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-
aggregate
- Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-
aggregate
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields) - Specified by:
aggregatein interfaceChainedFullAggregatorDeclarer
-