public class ChainedAggregatorDeclarer extends Object implements ChainedFullAggregatorDeclarer, ChainedPartitionAggregatorDeclarer
Modifier and Type | Class and Description |
---|---|
static interface |
ChainedAggregatorDeclarer.AggregationPartition |
Constructor and Description |
---|
ChainedAggregatorDeclarer(IAggregatableStream stream,
GlobalAggregationScheme globalScheme) |
public ChainedAggregatorDeclarer(IAggregatableStream stream, GlobalAggregationScheme globalScheme)
public Stream chainEnd()
chainEnd
in interface IChainedAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(Aggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(CombinerAggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(ReducerAggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedPartitionAggregatorDeclarer partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
partitionAggregate
in interface ChainedPartitionAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(Aggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(CombinerAggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(ReducerAggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
public ChainedFullAggregatorDeclarer aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
aggregate
in interface ChainedFullAggregatorDeclarer
Copyright © 2022 The Apache Software Foundation. All rights reserved.