Class RexImpTable.JsonArrayAggImplementor
- java.lang.Object
-
- org.apache.calcite.adapter.enumerable.RexImpTable.JsonArrayAggImplementor
-
- All Implemented Interfaces:
AggImplementor
- Enclosing class:
- RexImpTable
static class RexImpTable.JsonArrayAggImplementor extends java.lang.Object implements AggImplementor
Implementor for theJSON_ARRAYAGG
aggregate function.
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.reflect.Method
m
-
Constructor Summary
Constructors Constructor Description JsonArrayAggImplementor(java.lang.reflect.Method m)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<java.lang.reflect.Type>
getStateType(AggContext info)
Returns the types of the intermediate variables used by the aggregate implementation.void
implementAdd(AggContext info, AggAddContext add)
Updates intermediate values to account for the newly added value.void
implementReset(AggContext info, AggResetContext reset)
Implements reset of the intermediate variables to the initial state.Expression
implementResult(AggContext info, AggResultContext result)
Calculates the resulting value based on the intermediate variables.(package private) static java.util.function.Supplier<RexImpTable.JsonArrayAggImplementor>
supplierFor(java.lang.reflect.Method m)
-
-
-
Method Detail
-
supplierFor
static java.util.function.Supplier<RexImpTable.JsonArrayAggImplementor> supplierFor(java.lang.reflect.Method m)
-
getStateType
public java.util.List<java.lang.reflect.Type> getStateType(AggContext info)
Description copied from interface:AggImplementor
Returns the types of the intermediate variables used by the aggregate implementation.For instance, for "concatenate to string" this can be
StringBuilder
. Calcite calls this method before all otherimplement*
methods.- Specified by:
getStateType
in interfaceAggImplementor
- Parameters:
info
- Aggregate context- Returns:
- Types of the intermediate variables used by the aggregate implementation
-
implementReset
public void implementReset(AggContext info, AggResetContext reset)
Description copied from interface:AggImplementor
Implements reset of the intermediate variables to the initial state.AggResetContext.accumulator()
should be used to reference the state variables. For instance, to zero the count, use the following code:reset.currentBlock().add(
Expressions.statement(
Expressions.assign(reset.accumulator().get(0),
Expressions.constant(0)));- Specified by:
implementReset
in interfaceAggImplementor
- Parameters:
info
- Aggregate contextreset
- Reset context
-
implementAdd
public void implementAdd(AggContext info, AggAddContext add)
Description copied from interface:AggImplementor
Updates intermediate values to account for the newly added value.AggResetContext.accumulator()
should be used to reference the state variables.- Specified by:
implementAdd
in interfaceAggImplementor
- Parameters:
info
- Aggregate contextadd
- Add context
-
implementResult
public Expression implementResult(AggContext info, AggResultContext result)
Description copied from interface:AggImplementor
Calculates the resulting value based on the intermediate variables. Note: this method must NOT destroy the intermediate variables as calcite might reuse the state when calculating sliding aggregates.AggResetContext.accumulator()
should be used to reference the state variables.- Specified by:
implementResult
in interfaceAggImplementor
- Parameters:
info
- Aggregate contextresult
- Result context- Returns:
- Expression that is a result of calculating final value of the aggregate being implemented
-
-