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

public class SourceSorter<TAccumulate,TSource,TSortKey>
extends java.lang.Object

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

Field Summary

Fields

Modifier and Type	Field	Description
private Function2<TAccumulate,TSource,TAccumulate>	accumulatorAdder
private java.util.Comparator<TSortKey>	comparator
private Function1<TSource,TSortKey>	keySelector

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	sortAndAccumulate(java.lang.Iterable<TSource> sourceIterable, TAccumulate accumulator)

Methods inherited from class java.lang.Object

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

Field Detail

accumulatorAdder

private final Function2<TAccumulate,TSource,TAccumulate> accumulatorAdder

keySelector

private final Function1<TSource,TSortKey> keySelector

comparator

private final java.util.Comparator<TSortKey> comparator

Constructor Detail

SourceSorter

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

Method Detail

sortAndAccumulate

public void sortAndAccumulate(java.lang.Iterable<TSource> sourceIterable,
                              TAccumulate accumulator)