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
Nested ClassesModifier and TypeClassDescriptionstatic classImplementation ofSUMover BigDecimal values as a user-defined aggregate.static classImplementation ofSUMover DOUBLE values as a user-defined aggregate.static classImplementation ofSUMover INTEGER values as a user-defined aggregate.static classImplementation ofSUMover BIGINT values as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum ofBigDecimalvalues as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum ofbooleanvalues as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum ofdoubleandrealvalues as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum offloatvalues as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum ofintegervalues as a user-defined aggregate.static classImplementation ofMAXfunction to calculate the maximum oflongvalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum ofBigDecimalvalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum ofbooleanvalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum ofdoubleandrealvalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum offloatvalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum ofintegervalues as a user-defined aggregate.static classImplementation ofMINfunction to calculate the minimum oflongvalues as a user-defined aggregate.static classCommon implementation of comparison aggregate methods over numeric values as a user-defined aggregate. -
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
source
-
sink
-
rel
-
-
Constructor Details
-
AggregateNode
-
-
Method Details
-
run
- Throws:
InterruptedException
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceNode
-