FlinkSqlOperatorTable (Flink : 1.20-SNAPSHOT API)

java.lang.Object
- org.apache.calcite.sql.util.ReflectiveSqlOperatorTable
- - org.apache.flink.table.planner.functions.sql.FlinkSqlOperatorTable

All Implemented Interfaces:

org.apache.calcite.sql.SqlOperatorTable
```
public class FlinkSqlOperatorTable
extends org.apache.calcite.sql.util.ReflectiveSqlOperatorTable
```
Operator table that contains only Flink-specific functions and operators.

Field Summary

Fields
Modifier and Type	Field and Description
`static org.apache.calcite.sql.SqlFunction`	`ABS`
`static org.apache.calcite.sql.SqlFunction`	`ACOS`
`static org.apache.calcite.sql.SqlOperator`	`AND`
`static org.apache.calcite.sql.SqlAggFunction`	`APPROX_COUNT_DISTINCT`
`static org.apache.calcite.sql.SqlAggFunction`	`ARRAY_AGG` Use the definitions in Flink instead of `SqlLibraryOperators.ARRAY_AGG`, because we return nullable ARRAY type.
`static org.apache.calcite.sql.SqlOperator`	`ARRAY_VALUE_CONSTRUCTOR`
`static org.apache.calcite.sql.SqlOperator`	`AS`
`static org.apache.calcite.sql.SqlFunction`	`ASCII`
`static org.apache.calcite.sql.SqlFunction`	`ASIN`
`static org.apache.calcite.sql.SqlFunction`	`ATAN`
`static org.apache.calcite.sql.SqlFunction`	`ATAN2`
`static org.apache.calcite.sql.SqlAggFunction`	`AUXILIARY_GROUP` `AUXILIARY_GROUP` aggregate function.
`static org.apache.calcite.sql.SqlAggFunction`	`AVG`
`static org.apache.calcite.sql.SqlOperator`	`BETWEEN`
`static org.apache.calcite.sql.SqlFunction`	`BIN`
`static org.apache.calcite.sql.SqlOperator`	`CARDINALITY`
`static org.apache.calcite.sql.SqlOperator`	`CASE`
`static org.apache.calcite.sql.SqlFunction`	`CAST`
`static org.apache.calcite.sql.SqlFunction`	`CEIL`
`static org.apache.calcite.sql.SqlFunction`	`CHAR_LENGTH`
`static org.apache.calcite.sql.SqlFunction`	`CHARACTER_LENGTH`
`static org.apache.calcite.sql.SqlFunction`	`CHR`
`static org.apache.calcite.sql.SqlFunction`	`CLASSIFIER`
`static org.apache.calcite.sql.SqlAggFunction`	`COLLECT`
`static org.apache.calcite.sql.SqlOperator`	`CONCAT`
`static org.apache.calcite.sql.SqlFunction`	`CONCAT_FUNCTION` Function for concat strings, it is same with `CONCAT`, but this is a function.
`static org.apache.calcite.sql.SqlFunction`	`CONCAT_WS` Function for concat strings with a separator.
`static org.apache.calcite.sql.SqlFunction`	`CONVERT_TZ`
`static org.apache.calcite.sql.SqlFunction`	`COS`
`static org.apache.calcite.sql.SqlFunction`	`COSH`
`static org.apache.calcite.sql.SqlFunction`	`COT`
`static org.apache.calcite.sql.SqlAggFunction`	`COUNT`
`static org.apache.calcite.sql.SqlAggFunction`	`CUME_DIST`
`static org.apache.calcite.sql.SqlFunction`	`CUMULATE`
`static org.apache.calcite.sql.SqlFunction`	`CURRENT_DATABASE`
`static org.apache.calcite.sql.SqlFunction`	`CURRENT_ROW_TIMESTAMP`
`static org.apache.calcite.sql.SqlFunction`	`DATE_FORMAT`
`static org.apache.calcite.sql.SqlOperator`	`DATETIME_PLUS`
`static org.apache.calcite.sql.SqlFunction`	`DAYOFMONTH`
`static org.apache.calcite.sql.SqlFunction`	`DAYOFWEEK`
`static org.apache.calcite.sql.SqlFunction`	`DAYOFYEAR`
`static org.apache.calcite.sql.SqlFunction`	`DECODE`
`static org.apache.calcite.sql.SqlFunction`	`DEGREES`
`static org.apache.calcite.sql.SqlAggFunction`	`DENSE_RANK`
`static org.apache.calcite.sql.SqlOperator`	`DESC`
`static org.apache.calcite.sql.SqlOperator`	`DESCRIPTOR`
`static org.apache.calcite.sql.SqlOperator`	`DIVIDE`
`static org.apache.calcite.sql.SqlOperator`	`DIVIDE_INTEGER`
`static org.apache.calcite.sql.SqlOperator`	`DOT`
`static org.apache.calcite.sql.SqlFunction`	`E` Function to access the constant value of E.
`static org.apache.calcite.sql.SqlOperator`	`ELEMENT`
`static org.apache.calcite.sql.SqlFunction`	`ENCODE`
`static org.apache.calcite.sql.SqlOperator`	`EQUALS`
`static org.apache.calcite.sql.SqlOperator`	`EXCEPT`
`static org.apache.calcite.sql.SqlOperator`	`EXCEPT_ALL`
`static org.apache.calcite.sql.SqlOperator`	`EXISTS`
`static org.apache.calcite.sql.SqlFunction`	`EXP`
`static org.apache.calcite.sql.SqlOperator`	`EXTRACT`
`static org.apache.calcite.sql.SqlOperator`	`FINAL`
`static org.apache.calcite.sql.SqlFunction`	`FIRST`
`static SqlFirstLastValueAggFunction`	`FIRST_VALUE` `FIRST_VALUE` aggregate function.
`static org.apache.calcite.sql.SqlFunction`	`FLOOR`
`static org.apache.calcite.sql.SqlFunction`	`FROM_BASE64`
`static org.apache.calcite.sql.SqlFunction`	`FROM_UNIXTIME`
`static org.apache.calcite.sql.SqlOperator`	`GREATER_THAN`
`static org.apache.calcite.sql.SqlOperator`	`GREATER_THAN_OR_EQUAL`
`static org.apache.calcite.sql.SqlFunction`	`GROUP_ID`
`static org.apache.calcite.sql.SqlFunction`	`GROUPING`
`static org.apache.calcite.sql.SqlFunction`	`GROUPING_ID`
`static org.apache.calcite.sql.SqlFunction`	`HASH_CODE`
`static org.apache.calcite.sql.SqlFunction`	`HEX`
`static org.apache.calcite.sql.SqlFunction`	`HOP`
`static SqlGroupedWindowFunction`	`HOP_END`
`static SqlGroupedWindowFunction`	`HOP_OLD`
`static SqlGroupedWindowFunction`	`HOP_PROCTIME`
`static SqlGroupedWindowFunction`	`HOP_ROWTIME`
`static SqlGroupedWindowFunction`	`HOP_START`
`static org.apache.calcite.sql.SqlFunction`	`HOUR`
`static org.apache.calcite.sql.SqlFunction`	`IF`
`static org.apache.calcite.sql.SqlOperator`	`IGNORE_NULLS`
`static org.apache.calcite.sql.SqlOperator`	`IN`
`static org.apache.calcite.sql.SqlFunction`	`INITCAP`
`static org.apache.calcite.sql.SqlFunction`	`INSTR`
`static org.apache.calcite.sql.SqlOperator`	`INTERSECT`
`static org.apache.calcite.sql.SqlOperator`	`INTERSECT_ALL`
`static org.apache.calcite.sql.SqlFunction`	`IS_ALPHA`
`static org.apache.calcite.sql.SqlFunction`	`IS_DECIMAL`
`static org.apache.calcite.sql.SqlFunction`	`IS_DIGIT`
`static org.apache.calcite.sql.SqlOperator`	`IS_DISTINCT_FROM`
`static org.apache.calcite.sql.SqlOperator`	`IS_FALSE`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_JSON_ARRAY`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_JSON_OBJECT`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_JSON_SCALAR`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_JSON_VALUE`
`static org.apache.calcite.sql.SqlOperator`	`IS_NOT_DISTINCT_FROM`
`static org.apache.calcite.sql.SqlOperator`	`IS_NOT_FALSE`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_NOT_JSON_ARRAY`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_NOT_JSON_OBJECT`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_NOT_JSON_SCALAR`
`static org.apache.calcite.sql.SqlPostfixOperator`	`IS_NOT_JSON_VALUE`
`static org.apache.calcite.sql.SqlOperator`	`IS_NOT_NULL`
`static org.apache.calcite.sql.SqlOperator`	`IS_NOT_TRUE`
`static org.apache.calcite.sql.SqlOperator`	`IS_NOT_UNKNOWN`
`static org.apache.calcite.sql.SqlOperator`	`IS_NULL`
`static org.apache.calcite.sql.SqlOperator`	`IS_TRUE`
`static org.apache.calcite.sql.SqlOperator`	`IS_UNKNOWN`
`static org.apache.calcite.sql.SqlOperator`	`ITEM`
`static org.apache.calcite.sql.SqlFunction`	`JSON_ARRAY`
`static org.apache.calcite.sql.SqlAggFunction`	`JSON_ARRAYAGG_ABSENT_ON_NULL`
`static org.apache.calcite.sql.SqlAggFunction`	`JSON_ARRAYAGG_NULL_ON_NULL`
`static org.apache.calcite.sql.SqlFunction`	`JSON_EXISTS`
`static org.apache.calcite.sql.SqlFunction`	`JSON_OBJECT`
`static org.apache.calcite.sql.SqlAggFunction`	`JSON_OBJECTAGG_ABSENT_ON_NULL`
`static org.apache.calcite.sql.SqlAggFunction`	`JSON_OBJECTAGG_NULL_ON_NULL`
`static org.apache.calcite.sql.SqlFunction`	`JSON_QUERY`
`static org.apache.calcite.sql.SqlFunction`	`JSON_VALUE`
`static org.apache.calcite.sql.SqlAggFunction`	`LAG`
`static org.apache.calcite.sql.SqlFunction`	`LAST`
`static SqlFirstLastValueAggFunction`	`LAST_VALUE` `LAST_VALUE` aggregate function.
`static org.apache.calcite.sql.SqlAggFunction`	`LEAD`
`static org.apache.calcite.sql.SqlFunction`	`LEFT`
`static org.apache.calcite.sql.SqlOperator`	`LESS_THAN`
`static org.apache.calcite.sql.SqlOperator`	`LESS_THAN_OR_EQUAL`
`static org.apache.calcite.sql.SqlOperator`	`LIKE`
`static SqlListAggFunction`	`LISTAGG` `LISTAGG` aggregate function.
`static org.apache.calcite.sql.SqlOperator`	`LITERAL_CHAIN`
`static org.apache.calcite.sql.SqlFunction`	`LN`
`static org.apache.calcite.sql.SqlFunction`	`LOCATE`
`static org.apache.calcite.sql.SqlFunction`	`LOG`
`static org.apache.calcite.sql.SqlFunction`	`LOG10`
`static org.apache.calcite.sql.SqlFunction`	`LOG2`
`static org.apache.calcite.sql.SqlFunction`	`LOWER`
`static org.apache.calcite.sql.SqlFunction`	`LPAD`
`static org.apache.calcite.sql.SqlFunction`	`LTRIM`
`static org.apache.calcite.sql.SqlOperator`	`MAP_VALUE_CONSTRUCTOR`
`static org.apache.calcite.sql.SqlFunction`	`MATCH_PROCTIME` Function used to access a processing time attribute from MATCH_RECOGNIZE.
`static org.apache.calcite.sql.SqlFunction`	`MATCH_ROWTIME` Function used to access an event time attribute with TIMESTAMP or TIMESTAMP_LTZ type from MATCH_RECOGNIZE.
`static org.apache.calcite.sql.SqlAggFunction`	`MAX`
`static org.apache.calcite.sql.SqlFunction`	`MD5`
`static org.apache.calcite.sql.SqlAggFunction`	`MIN`
`static org.apache.calcite.sql.SqlOperator`	`MINUS`
`static org.apache.calcite.sql.SqlOperator`	`MINUS_DATE`
`static org.apache.calcite.sql.SqlFunction`	`MINUTE`
`static org.apache.calcite.sql.SqlFunction`	`MOD`
`static org.apache.calcite.sql.SqlFunction`	`MONTH`
`static org.apache.calcite.sql.SqlOperator`	`MULTIPLY`
`static org.apache.calcite.sql.SqlOperator`	`MULTISET_VALUE`
`static org.apache.calcite.sql.SqlFunction`	`NEXT`
`static org.apache.calcite.sql.SqlOperator`	`NOT`
`static org.apache.calcite.sql.SqlOperator`	`NOT_BETWEEN`
`static org.apache.calcite.sql.SqlOperator`	`NOT_EQUALS`
`static org.apache.calcite.sql.SqlOperator`	`NOT_IN`
`static org.apache.calcite.sql.SqlOperator`	`NOT_LIKE`
`static org.apache.calcite.sql.SqlOperator`	`NOT_SIMILAR_TO`
`static org.apache.calcite.sql.SqlAggFunction`	`NTILE`
`static org.apache.calcite.sql.SqlFunction`	`NULLIF`
`static org.apache.calcite.sql.SqlOperator`	`NULLS_FIRST`
`static org.apache.calcite.sql.SqlOperator`	`NULLS_LAST`
`static org.apache.calcite.sql.SqlOperator`	`OR`
`static org.apache.calcite.sql.SqlOperator`	`OVERLAPS`
`static org.apache.calcite.sql.SqlFunction`	`OVERLAY`
`static org.apache.calcite.sql.SqlFunction`	`PARSE_URL`
`static org.apache.calcite.sql.SqlAggFunction`	`PERCENT_RANK`
`static org.apache.calcite.sql.SqlOperator`	`PERCENT_REMAINDER`
`static org.apache.calcite.sql.SqlFunction`	`PI`
`static org.apache.calcite.sql.SqlFunction`	`PI_FUNCTION` Function to access the constant value of PI.
`static org.apache.calcite.sql.SqlOperator`	`PLUS`
`static org.apache.calcite.sql.SqlFunction`	`POSITION`
`static org.apache.calcite.sql.SqlFunction`	`POWER`
`static org.apache.calcite.sql.SqlFunction`	`PREV`
`static org.apache.calcite.sql.SqlFunction`	`PRINT`
`static org.apache.calcite.sql.SqlFunction`	`PROCTIME` Function used to access a processing time attribute.
`static org.apache.calcite.sql.SqlFunction`	`PROCTIME_MATERIALIZE` Function that materializes a processing time attribute.
`static org.apache.calcite.sql.SqlFunction`	`QUARTER`
`static org.apache.calcite.sql.SqlFunction`	`RADIANS`
`static org.apache.calcite.sql.SqlFunction`	`RAND`
`static org.apache.calcite.sql.SqlFunction`	`RAND_INTEGER`
`static org.apache.calcite.sql.SqlAggFunction`	`RANK`
`static org.apache.calcite.sql.SqlFunction`	`REGEXP`
`static org.apache.calcite.sql.SqlFunction`	`REGEXP_EXTRACT`
`static org.apache.calcite.sql.SqlFunction`	`REGEXP_REPLACE`
`static org.apache.calcite.sql.SqlOperator`	`REINTERPRET`
`static org.apache.calcite.sql.SqlFunction`	`REPEAT`
`static org.apache.calcite.sql.SqlFunction`	`REPLACE`
`static org.apache.calcite.sql.SqlOperator`	`RESPECT_NULLS`
`static org.apache.calcite.sql.SqlFunction`	`REVERSE`
`static org.apache.calcite.sql.SqlFunction`	`RIGHT`
`static org.apache.calcite.sql.SqlFunction`	`ROUND`
`static org.apache.calcite.sql.SqlOperator`	`ROW`
`static org.apache.calcite.sql.SqlAggFunction`	`ROW_NUMBER`
`static org.apache.calcite.sql.SqlFunction`	`RPAD`
`static org.apache.calcite.sql.SqlFunction`	`RTRIM`
`static org.apache.calcite.sql.SqlOperator`	`RUNNING`
`static org.apache.calcite.sql.SqlOperator`	`SCALAR_QUERY`
`static org.apache.calcite.sql.SqlOperator`	`SEARCH`
`static org.apache.calcite.sql.SqlFunction`	`SECOND`
`static org.apache.calcite.sql.SqlFunction`	`SESSION`
`static SqlGroupedWindowFunction`	`SESSION_END`
`static SqlGroupedWindowFunction`	`SESSION_OLD`
`static SqlGroupedWindowFunction`	`SESSION_PROCTIME`
`static SqlGroupedWindowFunction`	`SESSION_ROWTIME`
`static SqlGroupedWindowFunction`	`SESSION_START`
`static org.apache.calcite.sql.SqlFunction`	`SHA1`
`static org.apache.calcite.sql.SqlFunction`	`SHA2`
`static org.apache.calcite.sql.SqlFunction`	`SHA224`
`static org.apache.calcite.sql.SqlFunction`	`SHA256`
`static org.apache.calcite.sql.SqlFunction`	`SHA384`
`static org.apache.calcite.sql.SqlFunction`	`SHA512`
`static org.apache.calcite.sql.SqlFunction`	`SIGN`
`static org.apache.calcite.sql.SqlOperator`	`SIMILAR_TO`
`static org.apache.calcite.sql.SqlFunction`	`SIN`
`static org.apache.calcite.sql.SqlAggFunction`	`SINGLE_VALUE`
`static org.apache.calcite.sql.SqlFunction`	`SINH`
`static org.apache.calcite.sql.SqlPrefixOperator`	`SKIP_TO_FIRST`
`static org.apache.calcite.sql.SqlPrefixOperator`	`SKIP_TO_LAST`
`static org.apache.calcite.sql.SqlFunction`	`SPLIT_INDEX`
`static org.apache.calcite.sql.SqlFunction`	`SQRT`
`static org.apache.calcite.sql.SqlAggFunction`	`STDDEV`
`static org.apache.calcite.sql.SqlAggFunction`	`STDDEV_POP`
`static org.apache.calcite.sql.SqlAggFunction`	`STDDEV_SAMP`
`static org.apache.calcite.sql.SqlFunction`	`STR_TO_MAP`
`static org.apache.calcite.sql.SqlFunction`	`STREAMRECORD_TIMESTAMP` Function to access the timestamp of a StreamRecord.
`static org.apache.calcite.sql.SqlFunction`	`SUBSTR`
`static org.apache.calcite.sql.SqlFunction`	`SUBSTRING`
`static org.apache.calcite.sql.SqlAggFunction`	`SUM`
`static org.apache.calcite.sql.SqlAggFunction`	`SUM0`
`static org.apache.calcite.sql.SqlOperator`	`SYMMETRIC_BETWEEN`
`static org.apache.calcite.sql.SqlOperator`	`SYMMETRIC_NOT_BETWEEN`
`static org.apache.calcite.sql.SqlFunction`	`TAN`
`static org.apache.calcite.sql.SqlFunction`	`TANH`
`static org.apache.calcite.sql.SqlFunction`	`TIMESTAMP_ADD`
`static org.apache.calcite.sql.SqlFunction`	`TIMESTAMP_DIFF`
`static org.apache.calcite.sql.SqlFunction`	`TO_BASE64`
`static org.apache.calcite.sql.SqlFunction`	`TO_DATE`
`static org.apache.calcite.sql.SqlFunction`	`TO_TIMESTAMP`
`static org.apache.calcite.sql.SqlFunction`	`TO_TIMESTAMP_LTZ`
`static org.apache.calcite.sql.SqlFunction`	`TRIM`
`static org.apache.calcite.sql.SqlFunction`	`TRUNCATE`
`static org.apache.calcite.sql.SqlFunction`	`TRY_CAST`
`static org.apache.calcite.sql.SqlFunction`	`TUMBLE`
`static SqlGroupedWindowFunction`	`TUMBLE_END`
`static SqlGroupedWindowFunction`	`TUMBLE_OLD` We need custom group auxiliary functions in order to support nested windows.
`static SqlGroupedWindowFunction`	`TUMBLE_PROCTIME`
`static SqlGroupedWindowFunction`	`TUMBLE_ROWTIME`
`static SqlGroupedWindowFunction`	`TUMBLE_START`
`static org.apache.calcite.sql.SqlOperator`	`UNARY_MINUS`
`static org.apache.calcite.sql.SqlOperator`	`UNARY_PLUS`
`static org.apache.calcite.sql.SqlOperator`	`UNION`
`static org.apache.calcite.sql.SqlOperator`	`UNION_ALL`
`static org.apache.calcite.sql.SqlFunction`	`UNIX_TIMESTAMP`
`static org.apache.calcite.sql.SqlFunction`	`UPPER`
`static org.apache.calcite.sql.SqlFunction`	`UUID`
`static org.apache.calcite.sql.SqlAggFunction`	`VAR_POP`
`static org.apache.calcite.sql.SqlAggFunction`	`VAR_SAMP`
`static org.apache.calcite.sql.SqlAggFunction`	`VARIANCE`
`static org.apache.calcite.sql.SqlFunction`	`WEEK`
`static org.apache.calcite.sql.SqlFunction`	`YEAR`

Fields inherited from class org.apache.calcite.sql.util.ReflectiveSqlOperatorTable
IS_NAME

Constructor Summary

Constructors
Constructor and Description

FlinkSqlOperatorTable()

Constructors
Constructor and Description
`FlinkSqlOperatorTable()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`static List<org.apache.calcite.sql.SqlFunction>`	`dynamicFunctions(boolean isBatchMode)`
`static FlinkSqlOperatorTable`	`instance(boolean isBatchMode)` Returns the Flink operator table, creating it if necessary.
`void`	`lookupOperatorOverloads(org.apache.calcite.sql.SqlIdentifier opName, org.apache.calcite.sql.SqlFunctionCategory category, org.apache.calcite.sql.SqlSyntax syntax, List<org.apache.calcite.sql.SqlOperator> operatorList, org.apache.calcite.sql.validate.SqlNameMatcher nameMatcher)`

Methods inherited from class org.apache.calcite.sql.util.ReflectiveSqlOperatorTable
getOperatorList, init, register

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PROCTIME

public static final org.apache.calcite.sql.SqlFunction PROCTIME

Function used to access a processing time attribute.

MATCH_ROWTIME
```
public static final org.apache.calcite.sql.SqlFunction MATCH_ROWTIME
```
Function used to access an event time attribute with TIMESTAMP or TIMESTAMP_LTZ type from MATCH_RECOGNIZE.

MATCH_PROCTIME
```
public static final org.apache.calcite.sql.SqlFunction MATCH_PROCTIME
```
Function used to access a processing time attribute from MATCH_RECOGNIZE.

PROCTIME_MATERIALIZE
```
public static final org.apache.calcite.sql.SqlFunction PROCTIME_MATERIALIZE
```
Function that materializes a processing time attribute. After materialization the result can be used in regular arithmetical calculations.

STREAMRECORD_TIMESTAMP

public static final org.apache.calcite.sql.SqlFunction STREAMRECORD_TIMESTAMP

Function to access the timestamp of a StreamRecord.

E

public static final org.apache.calcite.sql.SqlFunction E

Function to access the constant value of E.

PI_FUNCTION

public static final org.apache.calcite.sql.SqlFunction PI_FUNCTION

Function to access the constant value of PI.

CONCAT_FUNCTION
```
public static final org.apache.calcite.sql.SqlFunction CONCAT_FUNCTION
```
Function for concat strings, it is same with CONCAT, but this is a function.

CONCAT_WS

public static final org.apache.calcite.sql.SqlFunction CONCAT_WS

Function for concat strings with a separator.

LOG

public static final org.apache.calcite.sql.SqlFunction LOG

LOG2

public static final org.apache.calcite.sql.SqlFunction LOG2

ROUND

public static final org.apache.calcite.sql.SqlFunction ROUND

TRUNCATE

public static final org.apache.calcite.sql.SqlFunction TRUNCATE

BIN

public static final org.apache.calcite.sql.SqlFunction BIN

SINH

public static final org.apache.calcite.sql.SqlFunction SINH

HEX

public static final org.apache.calcite.sql.SqlFunction HEX

STR_TO_MAP

public static final org.apache.calcite.sql.SqlFunction STR_TO_MAP

IS_DECIMAL

public static final org.apache.calcite.sql.SqlFunction IS_DECIMAL

IS_DIGIT

public static final org.apache.calcite.sql.SqlFunction IS_DIGIT

IS_ALPHA

public static final org.apache.calcite.sql.SqlFunction IS_ALPHA

COSH

public static final org.apache.calcite.sql.SqlFunction COSH

TANH

public static final org.apache.calcite.sql.SqlFunction TANH

CHR

public static final org.apache.calcite.sql.SqlFunction CHR

LPAD

public static final org.apache.calcite.sql.SqlFunction LPAD

RPAD

public static final org.apache.calcite.sql.SqlFunction RPAD

REPEAT

public static final org.apache.calcite.sql.SqlFunction REPEAT

REVERSE

public static final org.apache.calcite.sql.SqlFunction REVERSE

REPLACE

public static final org.apache.calcite.sql.SqlFunction REPLACE

SPLIT_INDEX

public static final org.apache.calcite.sql.SqlFunction SPLIT_INDEX

REGEXP_REPLACE

public static final org.apache.calcite.sql.SqlFunction REGEXP_REPLACE

REGEXP_EXTRACT

public static final org.apache.calcite.sql.SqlFunction REGEXP_EXTRACT

HASH_CODE

public static final org.apache.calcite.sql.SqlFunction HASH_CODE

MD5

public static final org.apache.calcite.sql.SqlFunction MD5

SHA1

public static final org.apache.calcite.sql.SqlFunction SHA1

SHA224

public static final org.apache.calcite.sql.SqlFunction SHA224

SHA256

public static final org.apache.calcite.sql.SqlFunction SHA256

SHA384

public static final org.apache.calcite.sql.SqlFunction SHA384

SHA512

public static final org.apache.calcite.sql.SqlFunction SHA512

SHA2

public static final org.apache.calcite.sql.SqlFunction SHA2

DATE_FORMAT

public static final org.apache.calcite.sql.SqlFunction DATE_FORMAT

REGEXP

public static final org.apache.calcite.sql.SqlFunction REGEXP

PARSE_URL

public static final org.apache.calcite.sql.SqlFunction PARSE_URL

PRINT

public static final org.apache.calcite.sql.SqlFunction PRINT

CURRENT_ROW_TIMESTAMP

public static final org.apache.calcite.sql.SqlFunction CURRENT_ROW_TIMESTAMP

UNIX_TIMESTAMP

public static final org.apache.calcite.sql.SqlFunction UNIX_TIMESTAMP

FROM_UNIXTIME

public static final org.apache.calcite.sql.SqlFunction FROM_UNIXTIME

IF

public static final org.apache.calcite.sql.SqlFunction IF

TO_BASE64

public static final org.apache.calcite.sql.SqlFunction TO_BASE64

FROM_BASE64

public static final org.apache.calcite.sql.SqlFunction FROM_BASE64

UUID

public static final org.apache.calcite.sql.SqlFunction UUID

SUBSTRING

public static final org.apache.calcite.sql.SqlFunction SUBSTRING

SUBSTR

public static final org.apache.calcite.sql.SqlFunction SUBSTR

LEFT

public static final org.apache.calcite.sql.SqlFunction LEFT

RIGHT

public static final org.apache.calcite.sql.SqlFunction RIGHT

TO_TIMESTAMP

public static final org.apache.calcite.sql.SqlFunction TO_TIMESTAMP

TO_TIMESTAMP_LTZ

public static final org.apache.calcite.sql.SqlFunction TO_TIMESTAMP_LTZ

TO_DATE

public static final org.apache.calcite.sql.SqlFunction TO_DATE

CONVERT_TZ

public static final org.apache.calcite.sql.SqlFunction CONVERT_TZ

LOCATE

public static final org.apache.calcite.sql.SqlFunction LOCATE

ASCII

public static final org.apache.calcite.sql.SqlFunction ASCII

ENCODE

public static final org.apache.calcite.sql.SqlFunction ENCODE

DECODE

public static final org.apache.calcite.sql.SqlFunction DECODE

INSTR

public static final org.apache.calcite.sql.SqlFunction INSTR

LTRIM

public static final org.apache.calcite.sql.SqlFunction LTRIM

RTRIM

public static final org.apache.calcite.sql.SqlFunction RTRIM

TRY_CAST

public static final org.apache.calcite.sql.SqlFunction TRY_CAST

RAND

public static final org.apache.calcite.sql.SqlFunction RAND

RAND_INTEGER

public static final org.apache.calcite.sql.SqlFunction RAND_INTEGER

AUXILIARY_GROUP
```
public static final org.apache.calcite.sql.SqlAggFunction AUXILIARY_GROUP
```
AUXILIARY_GROUP aggregate function. Only be used in internally.

FIRST_VALUE

public static final SqlFirstLastValueAggFunction FIRST_VALUE

FIRST_VALUE aggregate function.

LAST_VALUE

public static final SqlFirstLastValueAggFunction LAST_VALUE

LAST_VALUE aggregate function.

LISTAGG

public static final SqlListAggFunction LISTAGG

LISTAGG aggregate function.

TUMBLE_OLD
```
public static final SqlGroupedWindowFunction TUMBLE_OLD
```
We need custom group auxiliary functions in order to support nested windows.

TUMBLE_START

public static final SqlGroupedWindowFunction TUMBLE_START

TUMBLE_END

public static final SqlGroupedWindowFunction TUMBLE_END

TUMBLE_ROWTIME

public static final SqlGroupedWindowFunction TUMBLE_ROWTIME

TUMBLE_PROCTIME

public static final SqlGroupedWindowFunction TUMBLE_PROCTIME

HOP_OLD

public static final SqlGroupedWindowFunction HOP_OLD

HOP_START

public static final SqlGroupedWindowFunction HOP_START

HOP_END

public static final SqlGroupedWindowFunction HOP_END

HOP_ROWTIME

public static final SqlGroupedWindowFunction HOP_ROWTIME

HOP_PROCTIME

public static final SqlGroupedWindowFunction HOP_PROCTIME

SESSION_OLD

public static final SqlGroupedWindowFunction SESSION_OLD

SESSION_START

public static final SqlGroupedWindowFunction SESSION_START

SESSION_END

public static final SqlGroupedWindowFunction SESSION_END

SESSION_ROWTIME

public static final SqlGroupedWindowFunction SESSION_ROWTIME

SESSION_PROCTIME

public static final SqlGroupedWindowFunction SESSION_PROCTIME

UNION

public static final org.apache.calcite.sql.SqlOperator UNION

UNION_ALL

public static final org.apache.calcite.sql.SqlOperator UNION_ALL

EXCEPT

public static final org.apache.calcite.sql.SqlOperator EXCEPT

EXCEPT_ALL

public static final org.apache.calcite.sql.SqlOperator EXCEPT_ALL

INTERSECT

public static final org.apache.calcite.sql.SqlOperator INTERSECT

INTERSECT_ALL

public static final org.apache.calcite.sql.SqlOperator INTERSECT_ALL

AND

public static final org.apache.calcite.sql.SqlOperator AND

AS

public static final org.apache.calcite.sql.SqlOperator AS

CONCAT

public static final org.apache.calcite.sql.SqlOperator CONCAT

DIVIDE

public static final org.apache.calcite.sql.SqlOperator DIVIDE

DIVIDE_INTEGER

public static final org.apache.calcite.sql.SqlOperator DIVIDE_INTEGER

DOT

public static final org.apache.calcite.sql.SqlOperator DOT

EQUALS

public static final org.apache.calcite.sql.SqlOperator EQUALS

GREATER_THAN

public static final org.apache.calcite.sql.SqlOperator GREATER_THAN

IS_DISTINCT_FROM

public static final org.apache.calcite.sql.SqlOperator IS_DISTINCT_FROM

IS_NOT_DISTINCT_FROM

public static final org.apache.calcite.sql.SqlOperator IS_NOT_DISTINCT_FROM

GREATER_THAN_OR_EQUAL

public static final org.apache.calcite.sql.SqlOperator GREATER_THAN_OR_EQUAL

LESS_THAN

public static final org.apache.calcite.sql.SqlOperator LESS_THAN

LESS_THAN_OR_EQUAL

public static final org.apache.calcite.sql.SqlOperator LESS_THAN_OR_EQUAL

MINUS

public static final org.apache.calcite.sql.SqlOperator MINUS

MINUS_DATE

public static final org.apache.calcite.sql.SqlOperator MINUS_DATE

MULTIPLY

public static final org.apache.calcite.sql.SqlOperator MULTIPLY

NOT_EQUALS

public static final org.apache.calcite.sql.SqlOperator NOT_EQUALS

OR

public static final org.apache.calcite.sql.SqlOperator OR

PLUS

public static final org.apache.calcite.sql.SqlOperator PLUS

DATETIME_PLUS

public static final org.apache.calcite.sql.SqlOperator DATETIME_PLUS

PERCENT_REMAINDER

public static final org.apache.calcite.sql.SqlOperator PERCENT_REMAINDER

DESC

public static final org.apache.calcite.sql.SqlOperator DESC

NULLS_FIRST

public static final org.apache.calcite.sql.SqlOperator NULLS_FIRST

NULLS_LAST

public static final org.apache.calcite.sql.SqlOperator NULLS_LAST

IS_NOT_NULL

public static final org.apache.calcite.sql.SqlOperator IS_NOT_NULL

IS_NULL

public static final org.apache.calcite.sql.SqlOperator IS_NULL

IS_NOT_TRUE

public static final org.apache.calcite.sql.SqlOperator IS_NOT_TRUE

IS_TRUE

public static final org.apache.calcite.sql.SqlOperator IS_TRUE

IS_NOT_FALSE

public static final org.apache.calcite.sql.SqlOperator IS_NOT_FALSE

IS_FALSE

public static final org.apache.calcite.sql.SqlOperator IS_FALSE

IS_NOT_UNKNOWN

public static final org.apache.calcite.sql.SqlOperator IS_NOT_UNKNOWN

IS_UNKNOWN

public static final org.apache.calcite.sql.SqlOperator IS_UNKNOWN

NOT

public static final org.apache.calcite.sql.SqlOperator NOT

UNARY_MINUS

public static final org.apache.calcite.sql.SqlOperator UNARY_MINUS

UNARY_PLUS

public static final org.apache.calcite.sql.SqlOperator UNARY_PLUS

GROUP_ID

public static final org.apache.calcite.sql.SqlFunction GROUP_ID

GROUPING

public static final org.apache.calcite.sql.SqlFunction GROUPING

GROUPING_ID

public static final org.apache.calcite.sql.SqlFunction GROUPING_ID

SUM

public static final org.apache.calcite.sql.SqlAggFunction SUM

SUM0

public static final org.apache.calcite.sql.SqlAggFunction SUM0

COUNT

public static final org.apache.calcite.sql.SqlAggFunction COUNT

COLLECT

public static final org.apache.calcite.sql.SqlAggFunction COLLECT

MIN

public static final org.apache.calcite.sql.SqlAggFunction MIN

MAX

public static final org.apache.calcite.sql.SqlAggFunction MAX

AVG

public static final org.apache.calcite.sql.SqlAggFunction AVG

STDDEV

public static final org.apache.calcite.sql.SqlAggFunction STDDEV

STDDEV_POP

public static final org.apache.calcite.sql.SqlAggFunction STDDEV_POP

STDDEV_SAMP

public static final org.apache.calcite.sql.SqlAggFunction STDDEV_SAMP

VARIANCE

public static final org.apache.calcite.sql.SqlAggFunction VARIANCE

VAR_POP

public static final org.apache.calcite.sql.SqlAggFunction VAR_POP

VAR_SAMP

public static final org.apache.calcite.sql.SqlAggFunction VAR_SAMP

SINGLE_VALUE

public static final org.apache.calcite.sql.SqlAggFunction SINGLE_VALUE

APPROX_COUNT_DISTINCT

public static final org.apache.calcite.sql.SqlAggFunction APPROX_COUNT_DISTINCT

ARRAY_AGG
```
public static final org.apache.calcite.sql.SqlAggFunction ARRAY_AGG
```
Use the definitions in Flink instead of SqlLibraryOperators.ARRAY_AGG, because we return nullable ARRAY type. Order by clause like ARRAY_AGG(x ORDER BY x, y) for aggregate function is not supported yet, because the row data cannot be obtained inside the aggregate function.

ARRAY_VALUE_CONSTRUCTOR

public static final org.apache.calcite.sql.SqlOperator ARRAY_VALUE_CONSTRUCTOR

ELEMENT

public static final org.apache.calcite.sql.SqlOperator ELEMENT

MAP_VALUE_CONSTRUCTOR

public static final org.apache.calcite.sql.SqlOperator MAP_VALUE_CONSTRUCTOR

ITEM

public static final org.apache.calcite.sql.SqlOperator ITEM

CARDINALITY

public static final org.apache.calcite.sql.SqlOperator CARDINALITY

MULTISET_VALUE

public static final org.apache.calcite.sql.SqlOperator MULTISET_VALUE

ROW

public static final org.apache.calcite.sql.SqlOperator ROW

IGNORE_NULLS

public static final org.apache.calcite.sql.SqlOperator IGNORE_NULLS

RESPECT_NULLS

public static final org.apache.calcite.sql.SqlOperator RESPECT_NULLS

OVERLAPS

public static final org.apache.calcite.sql.SqlOperator OVERLAPS

LITERAL_CHAIN

public static final org.apache.calcite.sql.SqlOperator LITERAL_CHAIN

BETWEEN

public static final org.apache.calcite.sql.SqlOperator BETWEEN

SYMMETRIC_BETWEEN

public static final org.apache.calcite.sql.SqlOperator SYMMETRIC_BETWEEN

NOT_BETWEEN

public static final org.apache.calcite.sql.SqlOperator NOT_BETWEEN

SYMMETRIC_NOT_BETWEEN

public static final org.apache.calcite.sql.SqlOperator SYMMETRIC_NOT_BETWEEN

NOT_LIKE

public static final org.apache.calcite.sql.SqlOperator NOT_LIKE

LIKE

public static final org.apache.calcite.sql.SqlOperator LIKE

NOT_SIMILAR_TO

public static final org.apache.calcite.sql.SqlOperator NOT_SIMILAR_TO

SIMILAR_TO

public static final org.apache.calcite.sql.SqlOperator SIMILAR_TO

CASE

public static final org.apache.calcite.sql.SqlOperator CASE

REINTERPRET

public static final org.apache.calcite.sql.SqlOperator REINTERPRET

EXTRACT

public static final org.apache.calcite.sql.SqlOperator EXTRACT

IN

public static final org.apache.calcite.sql.SqlOperator IN

SEARCH

public static final org.apache.calcite.sql.SqlOperator SEARCH

NOT_IN

public static final org.apache.calcite.sql.SqlOperator NOT_IN

OVERLAY

public static final org.apache.calcite.sql.SqlFunction OVERLAY

TRIM

public static final org.apache.calcite.sql.SqlFunction TRIM

POSITION

public static final org.apache.calcite.sql.SqlFunction POSITION

CHAR_LENGTH

public static final org.apache.calcite.sql.SqlFunction CHAR_LENGTH

CHARACTER_LENGTH

public static final org.apache.calcite.sql.SqlFunction CHARACTER_LENGTH

UPPER

public static final org.apache.calcite.sql.SqlFunction UPPER

LOWER

public static final org.apache.calcite.sql.SqlFunction LOWER

INITCAP

public static final org.apache.calcite.sql.SqlFunction INITCAP

POWER

public static final org.apache.calcite.sql.SqlFunction POWER

SQRT

public static final org.apache.calcite.sql.SqlFunction SQRT

MOD

public static final org.apache.calcite.sql.SqlFunction MOD

LN

public static final org.apache.calcite.sql.SqlFunction LN

LOG10

public static final org.apache.calcite.sql.SqlFunction LOG10

ABS

public static final org.apache.calcite.sql.SqlFunction ABS

EXP

public static final org.apache.calcite.sql.SqlFunction EXP

NULLIF

public static final org.apache.calcite.sql.SqlFunction NULLIF

FLOOR

public static final org.apache.calcite.sql.SqlFunction FLOOR

CEIL

public static final org.apache.calcite.sql.SqlFunction CEIL

CAST

public static final org.apache.calcite.sql.SqlFunction CAST

SCALAR_QUERY

public static final org.apache.calcite.sql.SqlOperator SCALAR_QUERY

EXISTS

public static final org.apache.calcite.sql.SqlOperator EXISTS

SIN

public static final org.apache.calcite.sql.SqlFunction SIN

COS

public static final org.apache.calcite.sql.SqlFunction COS

TAN

public static final org.apache.calcite.sql.SqlFunction TAN

COT

public static final org.apache.calcite.sql.SqlFunction COT

ASIN

public static final org.apache.calcite.sql.SqlFunction ASIN

ACOS

public static final org.apache.calcite.sql.SqlFunction ACOS

ATAN

public static final org.apache.calcite.sql.SqlFunction ATAN

ATAN2

public static final org.apache.calcite.sql.SqlFunction ATAN2

DEGREES

public static final org.apache.calcite.sql.SqlFunction DEGREES

RADIANS

public static final org.apache.calcite.sql.SqlFunction RADIANS

SIGN

public static final org.apache.calcite.sql.SqlFunction SIGN

PI

public static final org.apache.calcite.sql.SqlFunction PI

YEAR

public static final org.apache.calcite.sql.SqlFunction YEAR

QUARTER

public static final org.apache.calcite.sql.SqlFunction QUARTER

MONTH

public static final org.apache.calcite.sql.SqlFunction MONTH

WEEK

public static final org.apache.calcite.sql.SqlFunction WEEK

HOUR

public static final org.apache.calcite.sql.SqlFunction HOUR

MINUTE

public static final org.apache.calcite.sql.SqlFunction MINUTE

SECOND

public static final org.apache.calcite.sql.SqlFunction SECOND

DAYOFYEAR

public static final org.apache.calcite.sql.SqlFunction DAYOFYEAR

DAYOFMONTH

public static final org.apache.calcite.sql.SqlFunction DAYOFMONTH

DAYOFWEEK

public static final org.apache.calcite.sql.SqlFunction DAYOFWEEK

TIMESTAMP_ADD

public static final org.apache.calcite.sql.SqlFunction TIMESTAMP_ADD

TIMESTAMP_DIFF

public static final org.apache.calcite.sql.SqlFunction TIMESTAMP_DIFF

FIRST

public static final org.apache.calcite.sql.SqlFunction FIRST

LAST

public static final org.apache.calcite.sql.SqlFunction LAST

public static final org.apache.calcite.sql.SqlFunction PREV

public static final org.apache.calcite.sql.SqlFunction NEXT

SKIP_TO_FIRST

public static final org.apache.calcite.sql.SqlPrefixOperator SKIP_TO_FIRST

SKIP_TO_LAST

public static final org.apache.calcite.sql.SqlPrefixOperator SKIP_TO_LAST

CLASSIFIER

public static final org.apache.calcite.sql.SqlFunction CLASSIFIER

FINAL

public static final org.apache.calcite.sql.SqlOperator FINAL

RUNNING

public static final org.apache.calcite.sql.SqlOperator RUNNING

RANK

public static final org.apache.calcite.sql.SqlAggFunction RANK

DENSE_RANK

public static final org.apache.calcite.sql.SqlAggFunction DENSE_RANK

ROW_NUMBER

public static final org.apache.calcite.sql.SqlAggFunction ROW_NUMBER

CUME_DIST

public static final org.apache.calcite.sql.SqlAggFunction CUME_DIST

PERCENT_RANK

public static final org.apache.calcite.sql.SqlAggFunction PERCENT_RANK

NTILE

public static final org.apache.calcite.sql.SqlAggFunction NTILE

LEAD

public static final org.apache.calcite.sql.SqlAggFunction LEAD

LAG

public static final org.apache.calcite.sql.SqlAggFunction LAG

JSON_EXISTS

public static final org.apache.calcite.sql.SqlFunction JSON_EXISTS

JSON_VALUE

public static final org.apache.calcite.sql.SqlFunction JSON_VALUE

JSON_QUERY

public static final org.apache.calcite.sql.SqlFunction JSON_QUERY

JSON_OBJECT

public static final org.apache.calcite.sql.SqlFunction JSON_OBJECT

JSON_OBJECTAGG_NULL_ON_NULL

public static final org.apache.calcite.sql.SqlAggFunction JSON_OBJECTAGG_NULL_ON_NULL

JSON_OBJECTAGG_ABSENT_ON_NULL

public static final org.apache.calcite.sql.SqlAggFunction JSON_OBJECTAGG_ABSENT_ON_NULL

JSON_ARRAY

public static final org.apache.calcite.sql.SqlFunction JSON_ARRAY

JSON_ARRAYAGG_NULL_ON_NULL

public static final org.apache.calcite.sql.SqlAggFunction JSON_ARRAYAGG_NULL_ON_NULL

JSON_ARRAYAGG_ABSENT_ON_NULL

public static final org.apache.calcite.sql.SqlAggFunction JSON_ARRAYAGG_ABSENT_ON_NULL

IS_JSON_VALUE

public static final org.apache.calcite.sql.SqlPostfixOperator IS_JSON_VALUE

IS_JSON_OBJECT

public static final org.apache.calcite.sql.SqlPostfixOperator IS_JSON_OBJECT

IS_JSON_ARRAY

public static final org.apache.calcite.sql.SqlPostfixOperator IS_JSON_ARRAY

IS_JSON_SCALAR

public static final org.apache.calcite.sql.SqlPostfixOperator IS_JSON_SCALAR

IS_NOT_JSON_VALUE

public static final org.apache.calcite.sql.SqlPostfixOperator IS_NOT_JSON_VALUE

IS_NOT_JSON_OBJECT

public static final org.apache.calcite.sql.SqlPostfixOperator IS_NOT_JSON_OBJECT

IS_NOT_JSON_ARRAY

public static final org.apache.calcite.sql.SqlPostfixOperator IS_NOT_JSON_ARRAY

IS_NOT_JSON_SCALAR

public static final org.apache.calcite.sql.SqlPostfixOperator IS_NOT_JSON_SCALAR

DESCRIPTOR

public static final org.apache.calcite.sql.SqlOperator DESCRIPTOR

TUMBLE

public static final org.apache.calcite.sql.SqlFunction TUMBLE

HOP

public static final org.apache.calcite.sql.SqlFunction HOP

CUMULATE

public static final org.apache.calcite.sql.SqlFunction CUMULATE

SESSION

public static final org.apache.calcite.sql.SqlFunction SESSION

CURRENT_DATABASE

public static final org.apache.calcite.sql.SqlFunction CURRENT_DATABASE

Constructor Detail
- FlinkSqlOperatorTable
```
public FlinkSqlOperatorTable()
```

Method Detail

instance

public static FlinkSqlOperatorTable instance(boolean isBatchMode)

Returns the Flink operator table, creating it if necessary.

dynamicFunctions

public static List<org.apache.calcite.sql.SqlFunction> dynamicFunctions(boolean isBatchMode)

lookupOperatorOverloads

public void lookupOperatorOverloads(org.apache.calcite.sql.SqlIdentifier opName,
                                    org.apache.calcite.sql.SqlFunctionCategory category,
                                    org.apache.calcite.sql.SqlSyntax syntax,
                                    List<org.apache.calcite.sql.SqlOperator> operatorList,
                                    org.apache.calcite.sql.validate.SqlNameMatcher nameMatcher)

Specified by:: lookupOperatorOverloads in interface org.apache.calcite.sql.SqlOperatorTable
Overrides:: lookupOperatorOverloads in class org.apache.calcite.sql.util.ReflectiveSqlOperatorTable

Back to Flink Website

Class FlinkSqlOperatorTable