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
Constructors Constructor Description GroupedStream(Stream stream, Fields groupFields)
-
Method Summary
-
-
-
Method Detail
-
name
public GroupedStream name(String name)
-
chainedAgg
public ChainedAggregatorDeclarer chainedAgg()
-
aggregate
public Stream aggregate(Aggregator agg, Fields functionFields)
-
aggregate
public Stream aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
-
aggregate
public Stream aggregate(CombinerAggregator agg, Fields functionFields)
-
aggregate
public Stream aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
-
aggregate
public Stream aggregate(ReducerAggregator agg, Fields functionFields)
-
aggregate
public Stream aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
-
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
public Stream stateQuery(TridentState state, QueryFunction function, Fields functionFields)
-
each
public IAggregatableStream each(Fields inputFields, Function function, Fields functionFields)
- Specified by:
each
in interfaceIAggregatableStream
-
partitionAggregate
public IAggregatableStream partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
- Specified by:
partitionAggregate
in interfaceIAggregatableStream
-
aggPartition
public IAggregatableStream aggPartition(GroupedStream s)
- Specified by:
aggPartition
in interfaceGlobalAggregationScheme<GroupedStream>
-
toStream
public Stream toStream()
- Specified by:
toStream
in interfaceIAggregatableStream
-
getOutputFields
public Fields getOutputFields()
- Specified by:
getOutputFields
in interfaceIAggregatableStream
-
getGroupFields
public Fields getGroupFields()
-
singleEmitPartitioner
public SingleEmitAggregator.BatchToPartition singleEmitPartitioner()
- Specified by:
singleEmitPartitioner
in interfaceGlobalAggregationScheme<GroupedStream>
-
-