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.
|
FlinkSqlTimestampFunction |
Function that used to define SQL time function like LOCALTIMESTAMP, CURRENT_TIMESTAMP,
CURRENT_ROW_TIMESTAMP(), NOW() in Flink, the function support configuring the return type and the
precision of return type.
|
ProctimeMaterializeSqlFunction |
Function that materializes a processing time attribute.
|
SqlArrayConstructor |
SqlOperator for ARRAY , which makes explicit casting if the element type not
equals the derived component type. |
SqlCumulateTableFunction |
SqlCumulateTableFunction implements an operator for cumulative.
|
SqlDescriptorOperator |
DESCRIPTOR appears as an argument in a function.
|
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. |
SqlHopTableFunction |
SqlHopTableFunction implements an operator for hopping.
|
SqlListAggFunction |
LISTAGG aggregate function returns the concatenation of a list of values that are
input to the function. |
SqlMapConstructor |
SqlOperator for MAP , which makes explicit casting if the element type not
equals the derived component type. |
SqlThrowExceptionFunction |
Function used to throw an exception, only used internally.
|
SqlTumbleTableFunction |
SqlTumbleTableFunction implements an operator for tumbling.
|
SqlWindowTableFunction |
Base class for a table-valued function that computes windows.
|
SqlWindowTableFunction.AbstractOperandMetadata |
Partial implementation of operand type checker.
|
StreamRecordTimestampSqlFunction |
Function to access the timestamp of a StreamRecord.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.