storm.trident.fluent
Class ChainedAggregatorDeclarer

java.lang.Object
  storm.trident.fluent.ChainedAggregatorDeclarer

All Implemented Interfaces:

ChainedFullAggregatorDeclarer, ChainedPartitionAggregatorDeclarer, IChainedAggregatorDeclarer

public class ChainedAggregatorDeclarer
extends java.lang.Object
implements ChainedFullAggregatorDeclarer, ChainedPartitionAggregatorDeclarer

Nested Class Summary

static interface

ChainedAggregatorDeclarer.AggregationPartition

Constructor Summary

ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)

Method Summary

ChainedFullAggregatorDeclarer	aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	aggregate(ReducerAggregator agg, Fields functionFields)
Stream	chainEnd()
ChainedPartitionAggregatorDeclarer	partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	partitionAggregate(CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	partitionAggregate(ReducerAggregator agg, Fields functionFields)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChainedAggregatorDeclarer

public ChainedAggregatorDeclarer(IAggregatableStream stream,
                                 GlobalAggregationScheme globalScheme)

Method Detail

chainEnd

public Stream chainEnd()

Specified by:

chainEnd in interface IChainedAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(Aggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields,
                                                             Aggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(CombinerAggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields,
                                                             CombinerAggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(ReducerAggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

partitionAggregate

public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields,
                                                             ReducerAggregator agg,
                                                             Fields functionFields)

Specified by:

partitionAggregate in interface ChainedPartitionAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(Aggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(Fields inputFields,
                                               Aggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(CombinerAggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(Fields inputFields,
                                               CombinerAggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(ReducerAggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer

aggregate

public ChainedFullAggregatorDeclarer aggregate(Fields inputFields,
                                               ReducerAggregator agg,
                                               Fields functionFields)

Specified by:

aggregate in interface ChainedFullAggregatorDeclarer