Uses of Interface
org.apache.storm.trident.operation.CombinerAggregator
-
-
Uses of CombinerAggregator in org.apache.storm.starter.trident
Classes in org.apache.storm.starter.trident that implement CombinerAggregator Modifier and Type Class Description static classTridentReach.One -
Uses of CombinerAggregator in org.apache.storm.trident
Methods in org.apache.storm.trident with parameters of type CombinerAggregator Modifier and Type Method Description StreamStream. aggregate(CombinerAggregator agg, Fields functionFields)StreamStream. aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)StreamStream. partitionAggregate(CombinerAggregator agg, Fields functionFields)StreamStream. partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)TridentStateStream. persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)TridentStateStream. persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)TridentStateStream. persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)TridentStateStream. persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) -
Uses of CombinerAggregator in org.apache.storm.trident.fluent
-
Uses of CombinerAggregator in org.apache.storm.trident.operation.builtin
Classes in org.apache.storm.trident.operation.builtin that implement CombinerAggregator Modifier and Type Class Description classCountclassSum -
Uses of CombinerAggregator in org.apache.storm.trident.operation.impl
Constructors in org.apache.storm.trident.operation.impl with parameters of type CombinerAggregator Constructor Description CombinerAggregatorCombineImpl(CombinerAggregator agg)CombinerAggregatorInitImpl(CombinerAggregator agg)CombinerAggStateUpdater(CombinerAggregator agg) -
Uses of CombinerAggregator in org.apache.storm.trident.state
Methods in org.apache.storm.trident.state that return CombinerAggregator Modifier and Type Method Description CombinerAggregatorCombinerValueUpdater. getAgg()Constructors in org.apache.storm.trident.state with parameters of type CombinerAggregator Constructor Description CombinerValueUpdater(CombinerAggregator agg, Object arg) -
Uses of CombinerAggregator in org.apache.storm.trident.state.map
Constructors in org.apache.storm.trident.state.map with parameters of type CombinerAggregator Constructor Description MapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields)
-