Package org.apache.storm.trident.fluent
Interface ChainedPartitionAggregatorDeclarer
- All Superinterfaces:
IChainedAggregatorDeclarer
- All Known Implementing Classes:
ChainedAggregatorDeclarer
-
Method Summary
Modifier and TypeMethodDescriptionpartitionAggregate
(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) Methods inherited from interface org.apache.storm.trident.fluent.IChainedAggregatorDeclarer
chainEnd
-
Method Details
-
partitionAggregate
-
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) -
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(CombinerAggregator agg, Fields functionFields) -
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) -
partitionAggregate
-
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
-