Package org.apache.storm.trident.fluent
Class GroupedStream
java.lang.Object
org.apache.storm.trident.fluent.GroupedStream
- All Implemented Interfaces:
GlobalAggregationScheme<GroupedStream>
,IAggregatableStream
public class GroupedStream
extends Object
implements IAggregatableStream, GlobalAggregationScheme<GroupedStream>
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionaggregate
(Aggregator agg, Fields functionFields) aggregate
(CombinerAggregator agg, Fields functionFields) aggregate
(ReducerAggregator agg, Fields functionFields) aggregate
(Fields inputFields, Aggregator agg, Fields functionFields) aggregate
(Fields inputFields, CombinerAggregator agg, Fields functionFields) aggregate
(Fields inputFields, ReducerAggregator agg, Fields functionFields) partitionAggregate
(Fields inputFields, Aggregator agg, Fields functionFields) persistentAggregate
(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields) persistentAggregate
(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields) persistentAggregate
(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields) persistentAggregate
(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields) persistentAggregate
(StateSpec spec, CombinerAggregator agg, Fields functionFields) persistentAggregate
(StateSpec spec, ReducerAggregator agg, Fields functionFields) persistentAggregate
(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) persistentAggregate
(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) stateQuery
(TridentState state, QueryFunction function, Fields functionFields) stateQuery
(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields) toStream()
-
Constructor Details
-
GroupedStream
-
-
Method Details
-
name
-
chainedAgg
-
aggregate
-
aggregate
-
aggregate
-
aggregate
-
aggregate
-
aggregate
-
persistentAggregate
public TridentState persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields) -
persistentAggregate
public TridentState persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields) -
stateQuery
public Stream stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields) -
stateQuery
-
each
- Specified by:
each
in interfaceIAggregatableStream
-
partitionAggregate
public IAggregatableStream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields) - Specified by:
partitionAggregate
in interfaceIAggregatableStream
-
aggPartition
- Specified by:
aggPartition
in interfaceGlobalAggregationScheme<GroupedStream>
-
toStream
- Specified by:
toStream
in interfaceIAggregatableStream
-
getOutputFields
- Specified by:
getOutputFields
in interfaceIAggregatableStream
-
getGroupFields
-
singleEmitPartitioner
- Specified by:
singleEmitPartitioner
in interfaceGlobalAggregationScheme<GroupedStream>
-