Package org.apache.calcite.adapter.enumerable

Class LazyAggregateLambdaFactory<TSource,TKey,TOrigAccumulate,TResult>

java.lang.Object

org.apache.calcite.adapter.enumerable.LazyAggregateLambdaFactory<TSource,TKey,TOrigAccumulate,TResult>

Type Parameters:

TSource - Type of the enumerable input source

TKey - Type of the group-by key

TOrigAccumulate - Type of the original accumulator

TResult - Type of the enumerable output result

All Implemented Interfaces:

AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>

public class LazyAggregateLambdaFactory<TSource,TKey,TOrigAccumulate,TResult>
extends Object
implements AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>

Generate aggregate lambdas that preserve the input source before calling each aggregate adder, this implementation is generally used when we need to sort the input before performing aggregation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	LazyAggregateLambdaFactory.LazyAccumulator<TOrigAccumulate,TSource>	Accumulate on the cached input sources.
static class	LazyAggregateLambdaFactory.LazySource<TSource>	Cache the input sources.

Constructor Summary

Constructors

Constructor	Description
LazyAggregateLambdaFactory(Function0<TOrigAccumulate> accumulatorInitializer, List<LazyAggregateLambdaFactory.LazyAccumulator<TOrigAccumulate,TSource>> accumulators)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

LazyAggregateLambdaFactory

public LazyAggregateLambdaFactory(Function0<TOrigAccumulate> accumulatorInitializer,
 List<LazyAggregateLambdaFactory.LazyAccumulator<TOrigAccumulate,TSource>> accumulators)

Method Details

accumulatorInitializer

public Function0<LazyAggregateLambdaFactory.LazySource<TSource>> accumulatorInitializer()

Specified by:

accumulatorInitializer in interface AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>

accumulatorAdder

public Function2<LazyAggregateLambdaFactory.LazySource<TSource>,TSource,LazyAggregateLambdaFactory.LazySource<TSource>> accumulatorAdder()

Specified by:

accumulatorAdder in interface AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>

singleGroupResultSelector

public Function1<LazyAggregateLambdaFactory.LazySource<TSource>,TResult> singleGroupResultSelector(Function1<TOrigAccumulate,TResult> resultSelector)

Specified by:

singleGroupResultSelector in interface AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>

resultSelector

public Function2<TKey,LazyAggregateLambdaFactory.LazySource<TSource>,TResult> resultSelector(Function2<TKey,TOrigAccumulate,TResult> resultSelector)

Specified by:

resultSelector in interface AggregateLambdaFactory<TSource,TOrigAccumulate,LazyAggregateLambdaFactory.LazySource<TSource>,TResult,TKey>