Package org.apache.calcite.interpreter

Class AggregateNode

java.lang.Object

org.apache.calcite.interpreter.AbstractSingleNode<Aggregate>

org.apache.calcite.interpreter.AggregateNode

All Implemented Interfaces:

Node

public class AggregateNode
extends AbstractSingleNode<Aggregate>

Interpreter node that implements an Aggregate.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	AggregateNode.Accumulator	Defines function implementation for things like count() and sum().
private static interface	AggregateNode.AccumulatorFactory	Creates an AggregateNode.Accumulator.
private static class	AggregateNode.AccumulatorList	A list of accumulators used during grouping.
private static class	AggregateNode.CountAccumulator	Accumulator for calls to the COUNT function.
static class	AggregateNode.DoubleSum	Implementation of SUM over DOUBLE values as a user-defined aggregate.
private static class	AggregateNode.FilterAccumulator	Accumulator that applies a filter to another accumulator.
private class	AggregateNode.Grouping	Internal class to track groupings.
static class	AggregateNode.IntSum	Implementation of SUM over INTEGER values as a user-defined aggregate.
static class	AggregateNode.LongSum	Implementation of SUM over BIGINT values as a user-defined aggregate.
static class	AggregateNode.MaxDouble	Implementation of MAX function to calculate the minimum of double and real values as a user-defined aggregate.
static class	AggregateNode.MaxFloat	Implementation of MAX function to calculate the minimum of float values as a user-defined aggregate.
static class	AggregateNode.MaxInt	Implementation of MAX function to calculate the minimum of integer values as a user-defined aggregate.
static class	AggregateNode.MaxLong	Implementation of MAX function to calculate the minimum of long values as a user-defined aggregate.
static class	AggregateNode.MinDouble	Implementation of MIN function to calculate the minimum of double and real values as a user-defined aggregate.
static class	AggregateNode.MinFloat	Implementation of MIN function to calculate the minimum of float values as a user-defined aggregate.
static class	AggregateNode.MinInt	Implementation of MIN function to calculate the minimum of integer values as a user-defined aggregate.
static class	AggregateNode.MinLong	Implementation of MIN function to calculate the minimum of long values as a user-defined aggregate.
static class	AggregateNode.NumericComparison<T>	Common implementation of comparison aggregate methods over numeric values as a user-defined aggregate.
private static class	AggregateNode.ScalarAccumulator	Accumulator powered by Scalar code fragments.
private static class	AggregateNode.ScalarAccumulatorDef	Accumulator powered by Scalar code fragments.
private static class	AggregateNode.UdaAccumulator	Accumulator based upon a user-defined aggregate.
private static class	AggregateNode.UdaAccumulatorFactory	Accumulator factory based on a user-defined aggregate function.

Field Summary

Fields

Modifier and Type	Field	Description
private com.google.common.collect.ImmutableList<AggregateNode.AccumulatorFactory>	accumulatorFactories
private DataContext	dataContext
private java.util.List<AggregateNode.Grouping>	groups
private int	outputRowLength
private ImmutableBitSet	unionGroups

Fields inherited from class org.apache.calcite.interpreter.AbstractSingleNode

rel, sink, source

Constructor Summary

Constructors

Constructor	Description
AggregateNode(Compiler compiler, Aggregate rel)

Method Summary

Modifier and Type	Method	Description
private AggregateNode.AccumulatorFactory	getAccumulator(AggregateCall call, boolean ignoreFilter)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

groups

private final java.util.List<AggregateNode.Grouping> groups

unionGroups

private final ImmutableBitSet unionGroups

outputRowLength

private final int outputRowLength

accumulatorFactories

private final com.google.common.collect.ImmutableList<AggregateNode.AccumulatorFactory> accumulatorFactories

dataContext

private final DataContext dataContext

Constructor Detail

AggregateNode

public AggregateNode(Compiler compiler,
                     Aggregate rel)

Method Detail

run

public void run()
         throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getAccumulator

private AggregateNode.AccumulatorFactory getAccumulator(AggregateCall call,
                                                        boolean ignoreFilter)