Package org.apache.calcite.interpreter
Class AggregateNode
java.lang.Object
org.apache.calcite.interpreter.AggregateNode
- All Implemented Interfaces:
AutoCloseable
,Node
Interpreter node that implements an
Aggregate
.-
Nested Class Summary
Modifier and TypeClassDescriptionstatic class
Implementation ofSUM
over BigDecimal values as a user-defined aggregate.static class
Implementation ofSUM
over DOUBLE values as a user-defined aggregate.static class
Implementation ofSUM
over INTEGER values as a user-defined aggregate.static class
Implementation ofSUM
over BIGINT values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum ofBigDecimal
values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum ofboolean
values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum ofdouble
andreal
values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum offloat
values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum ofinteger
values as a user-defined aggregate.static class
Implementation ofMAX
function to calculate the maximum oflong
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum ofBigDecimal
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum ofboolean
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum ofdouble
andreal
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum offloat
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum ofinteger
values as a user-defined aggregate.static class
Implementation ofMIN
function to calculate the minimum oflong
values as a user-defined aggregate.static class
Common implementation of comparison aggregate methods over numeric values as a user-defined aggregate. -
Field Summary
-
Constructor Summary
-
Method Summary
-
Field Details
-
source
-
sink
-
rel
-
-
Constructor Details
-
AggregateNode
-
-
Method Details
-
run
- Throws:
InterruptedException
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceNode
-