Class | Description |
---|---|
CalciteSqlFunction |
This is a simple override class for Calcite's
SqlFunction which provide CalciteSqlFunction.isDeterministic() as a constructor parameter to simplify construct a new SqlFunction in
FlinkSqlOperatorTable . |
FlinkSqlOperatorTable |
Operator table that contains only Flink-specific functions and operators.
|
ProctimeMaterializeSqlFunction |
Function that materializes a processing time attribute.
|
SqlFirstLastValueAggFunction |
FIRST_VALUE and LAST_VALUE aggregate functions return the first or the
last value in a list of values that are input to the function. |
SqlListAggFunction |
LISTAGG aggregate function returns the concatenation of a list of values that are
input to the function. |
SqlThrowExceptionFunction |
Function used to throw an exception, only used internally.
|
StreamRecordTimestampSqlFunction |
Function to access the timestamp of a StreamRecord.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.