org.apache.flink.table.planner.functions.sql

Class SqlCumulateTableFunction

java.lang.Object

org.apache.calcite.sql.SqlOperator

org.apache.calcite.sql.SqlFunction

org.apache.flink.table.planner.functions.sql.SqlWindowTableFunction

org.apache.flink.table.planner.functions.sql.SqlCumulateTableFunction

All Implemented Interfaces:

org.apache.calcite.sql.SqlTableFunction

public class SqlCumulateTableFunction
extends SqlWindowTableFunction

SqlCumulateTableFunction implements an operator for cumulative.

It allows four parameters:

1. a table
2. a descriptor to provide a time attribute column name from the input table
3. an interval parameter to specify the window size to increase.
4. an interval parameter to specify the max length of window size

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.planner.functions.sql.SqlWindowTableFunction

SqlWindowTableFunction.AbstractOperandMetadata

Field Summary

Fields inherited from class org.apache.flink.table.planner.functions.sql.SqlWindowTableFunction

ARG0_TABLE_FUNCTION_WINDOWING, PARAM_DATA, PARAM_KEY, PARAM_OFFSET, PARAM_SIZE, PARAM_SLIDE, PARAM_STEP, PARAM_TIMECOL

Fields inherited from class org.apache.calcite.sql.SqlOperator

kind, MDX_PRECEDENCE, NL

Constructor Summary

Constructors

Constructor and Description
SqlCumulateTableFunction()

Method Summary

Methods inherited from class org.apache.flink.table.planner.functions.sql.SqlWindowTableFunction

argumentMustBeScalar, getOperandTypeChecker, getRowTypeInference, inferRowType

Methods inherited from class org.apache.calcite.sql.SqlFunction

deriveType, getFunctionType, getNameAsId, getParamNames, getParamTypes, getSqlIdentifier, getSyntax, isQuantifierAllowed, unparse, validateCall, validateQuantifier

Methods inherited from class org.apache.calcite.sql.SqlOperator

acceptCall, acceptCall, adjustType, allowsFraming, checkOperandCount, checkOperandTypes, constructArgNameList, constructArgTypeList, constructOperandList, createCall, createCall, createCall, createCall, equals, getAllowedSignatures, getAllowedSignatures, getKind, getLeftPrec, getMonotonicity, getMonotonicity, getName, getOperandCountRange, getOperandTypeInference, getReturnTypeInference, getRightPrec, getSignatureTemplate, getStrongPolicyInference, hashCode, inferReturnType, inferReturnType, isAggregator, isDeterministic, isDynamicFunction, isGroup, isGroupAuxiliary, isName, isSymmetrical, leftPrec, preValidateCall, requiresDecimalExpansion, requiresOrder, requiresOver, rewriteCall, rightPrec, toString, unparseListClause, unparseListClause, validateOperands, validRexOperands

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SqlCumulateTableFunction

public SqlCumulateTableFunction()