Uses of Interface
org.apache.storm.trident.operation.CombinerAggregator
Package
Description
-
Uses of CombinerAggregator in org.apache.storm.starter.trident
-
Uses of CombinerAggregator in org.apache.storm.trident
Modifier 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.fluent
Modifier 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.builtin
-
Uses of CombinerAggregator in org.apache.storm.trident.operation.impl
ModifierConstructorDescription -
Uses of CombinerAggregator in org.apache.storm.trident.state
-
Uses of CombinerAggregator in org.apache.storm.trident.state.map
ModifierConstructorDescriptionMapCombinerAggStateUpdater
(CombinerAggregator agg, Fields groupFields, Fields inputFields)