Uses of Interface
org.apache.storm.trident.operation.CombinerAggregator
Packages that use CombinerAggregator
Package
Description
- 
Uses of CombinerAggregator in org.apache.storm.starter.tridentClasses in org.apache.storm.starter.trident that implement CombinerAggregator
- 
Uses of CombinerAggregator in org.apache.storm.tridentMethods in org.apache.storm.trident with parameters of type CombinerAggregatorModifier and TypeMethodDescriptionStream.aggregate(CombinerAggregator agg, Fields functionFields) Stream.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) Stream.partitionAggregate(CombinerAggregator agg, Fields functionFields) Stream.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields) Stream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) 
- 
Uses of CombinerAggregator in org.apache.storm.trident.fluentMethods in org.apache.storm.trident.fluent with parameters of type CombinerAggregatorModifier and TypeMethodDescriptionChainedAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) ChainedFullAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields) ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) GroupedStream.aggregate(CombinerAggregator agg, Fields functionFields) GroupedStream.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields) ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) ChainedPartitionAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields) ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields) GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) 
- 
Uses of CombinerAggregator in org.apache.storm.trident.operation.builtinClasses in org.apache.storm.trident.operation.builtin that implement CombinerAggregator
- 
Uses of CombinerAggregator in org.apache.storm.trident.operation.implConstructors in org.apache.storm.trident.operation.impl with parameters of type CombinerAggregatorModifierConstructorDescription
- 
Uses of CombinerAggregator in org.apache.storm.trident.stateMethods in org.apache.storm.trident.state that return CombinerAggregatorConstructors in org.apache.storm.trident.state with parameters of type CombinerAggregator
- 
Uses of CombinerAggregator in org.apache.storm.trident.state.mapConstructors in org.apache.storm.trident.state.map with parameters of type CombinerAggregatorModifierConstructorDescriptionMapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields)