Package org.apache.calcite.adapter.enumerable

Class BasicAggregateLambdaFactory<TSource,TAccumulate,TResult,TKey>

java.lang.Object

org.apache.calcite.adapter.enumerable.BasicAggregateLambdaFactory<TSource,TAccumulate,TResult,TKey>

Type Parameters:

TSource - Type of the enumerable input source

TAccumulate - Type of the accumulator

TResult - Type of the enumerable output result

TKey - Type of the group-by key

All Implemented Interfaces:

AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>

public class BasicAggregateLambdaFactory<TSource,TAccumulate,TResult,TKey>
extends Object
implements AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>

Implementation of AggregateLambdaFactory that applies a sequence of accumulator adders to input source.

Constructor Summary

Constructors

Constructor	Description
BasicAggregateLambdaFactory(Function0<TAccumulate> accumulatorInitializer, List<Function2<TAccumulate,TSource,TAccumulate>> accumulatorAdders)

Method Summary

Modifier and Type	Method	Description
Function2<TAccumulate,TSource,TAccumulate>	accumulatorAdder()
Function0<TAccumulate>	accumulatorInitializer()
Function2<TKey,TAccumulate,TResult>	resultSelector(Function2<TKey,TAccumulate,TResult> resultSelector)
Function1<TAccumulate,TResult>	singleGroupResultSelector(Function1<TAccumulate,TResult> resultSelector)

Methods inherited from class java.lang.Object

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

Constructor Details

BasicAggregateLambdaFactory

public BasicAggregateLambdaFactory(Function0<TAccumulate> accumulatorInitializer,
 List<Function2<TAccumulate,TSource,TAccumulate>> accumulatorAdders)

Method Details

accumulatorInitializer

public Function0<TAccumulate> accumulatorInitializer()

Specified by:

accumulatorInitializer in interface AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>

accumulatorAdder

public Function2<TAccumulate,TSource,TAccumulate> accumulatorAdder()

Specified by:

accumulatorAdder in interface AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>

singleGroupResultSelector

public Function1<TAccumulate,TResult> singleGroupResultSelector(Function1<TAccumulate,TResult> resultSelector)

Specified by:

singleGroupResultSelector in interface AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>

resultSelector

public Function2<TKey,TAccumulate,TResult> resultSelector(Function2<TKey,TAccumulate,TResult> resultSelector)

Specified by:

resultSelector in interface AggregateLambdaFactory<TSource,TAccumulate,TAccumulate,TResult,TKey>