Package org.apache.calcite.interpreter
Class AggregateNode.ScalarAccumulatorDef
- java.lang.Object
-
- org.apache.calcite.interpreter.AggregateNode.ScalarAccumulatorDef
-
- All Implemented Interfaces:
java.util.function.Supplier<AggregateNode.Accumulator>
,AggregateNode.AccumulatorFactory
- Enclosing class:
- AggregateNode
private static class AggregateNode.ScalarAccumulatorDef extends java.lang.Object implements AggregateNode.AccumulatorFactory
Accumulator powered byScalar
code fragments.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) int
accumulatorLength
(package private) Scalar
addScalar
(package private) Context
endContext
(package private) Scalar
endScalar
(package private) Scalar
initScalar
(package private) int
rowLength
(package private) Context
sendContext
-
Constructor Summary
Constructors Modifier Constructor Description private
ScalarAccumulatorDef(Scalar initScalar, Scalar addScalar, Scalar endScalar, int rowLength, int accumulatorLength, DataContext root)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AggregateNode.Accumulator
get()
-
-
-
Constructor Detail
-
ScalarAccumulatorDef
private ScalarAccumulatorDef(Scalar initScalar, Scalar addScalar, Scalar endScalar, int rowLength, int accumulatorLength, DataContext root)
-
-
Method Detail
-
get
public AggregateNode.Accumulator get()
- Specified by:
get
in interfacejava.util.function.Supplier<AggregateNode.Accumulator>
-
-