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–2020 The Apache Software Foundation. All rights reserved.