storm.trident.fluent
Interface ChainedPartitionAggregatorDeclarer
- All Superinterfaces:
- IChainedAggregatorDeclarer
- All Known Implementing Classes:
- ChainedAggregatorDeclarer
public interface ChainedPartitionAggregatorDeclarer
- extends IChainedAggregatorDeclarer
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(Aggregator agg,
Fields functionFields)
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
ChainedPartitionAggregatorDeclarer partitionAggregate(ReducerAggregator agg,
Fields functionFields)
partitionAggregate
ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields,
ReducerAggregator agg,
Fields functionFields)