Package org.apache.calcite.adapter.enumerable

Class SourceSorter<TAccumulate,TSource,TSortKey>

java.lang.Object

org.apache.calcite.adapter.enumerable.SourceSorter<TAccumulate,TSource,TSortKey>

Type Parameters:

TAccumulate - Type of the accumulator

TSource - Type of the enumerable input source

TSortKey - Type of the sort key

All Implemented Interfaces:

LazyAggregateLambdaFactory.LazyAccumulator<TAccumulate,TSource>

public class SourceSorter<TAccumulate,TSource,TSortKey>
extends Object
implements LazyAggregateLambdaFactory.LazyAccumulator<TAccumulate,TSource>

Helper that combines the sorting process and accumulating process against the aggregate execution, used with LazyAggregateLambdaFactory.

Constructor Summary

Constructors

Constructor	Description
SourceSorter(Function2<TAccumulate,TSource,TAccumulate> accumulatorAdder, Function1<TSource,TSortKey> keySelector, Comparator<TSortKey> comparator)

Method Summary

Modifier and Type	Method	Description
void	accumulate(Iterable<TSource> sourceIterable, TAccumulate accumulator)

Methods inherited from class java.lang.Object

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

Constructor Details

SourceSorter

public SourceSorter(Function2<TAccumulate,TSource,TAccumulate> accumulatorAdder,
 Function1<TSource,TSortKey> keySelector,
 Comparator<TSortKey> comparator)

Method Details

accumulate

public void accumulate(Iterable<TSource> sourceIterable,
 TAccumulate accumulator)

Specified by:

accumulate in interface LazyAggregateLambdaFactory.LazyAccumulator<TAccumulate,TSource>