Package org.apache.flink.cdc.runtime.parser.metadata

Class TransformSqlOperatorTable

java.lang.Object

org.apache.calcite.sql.util.ReflectiveSqlOperatorTable

org.apache.flink.cdc.runtime.parser.metadata.TransformSqlOperatorTable

All Implemented Interfaces:

org.apache.calcite.sql.SqlOperatorTable

public class TransformSqlOperatorTable
extends org.apache.calcite.sql.util.ReflectiveSqlOperatorTable

TransformSqlOperatorTable to generate the metadata of calcite.

Field Summary

Fields

Modifier and Type	Field	Description
static org.apache.calcite.sql.SqlFunction	ABS
static org.apache.calcite.sql.SqlFunction	AI_CHAT_PREDICT
static org.apache.calcite.sql.SqlFunction	AI_LANGCHAIN_PREDICT
static org.apache.calcite.sql.SqlBinaryOperator	AND
static org.apache.calcite.sql.SqlOperator	ARRAY
static org.apache.calcite.sql.SqlFunction	ARRAY_CONTAINS
static org.apache.calcite.sql.SqlFunction	ARRAY_POSITION
static org.apache.calcite.sql.fun.SqlBetweenOperator	BETWEEN
static org.apache.calcite.sql.SqlFunction	BTRIM
static org.apache.calcite.sql.SqlFunction	CARDINALITY
static org.apache.calcite.sql.fun.SqlCaseOperator	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	COALESCE
static org.apache.calcite.sql.SqlBinaryOperator	CONCAT
static org.apache.calcite.sql.SqlFunction	CONCAT_FUNCTION
static org.apache.calcite.sql.SqlFunction	CONCAT_WS
static org.apache.calcite.sql.SqlFunction	CURRENT_DATE
static org.apache.calcite.sql.SqlFunction	CURRENT_TIME
static org.apache.calcite.sql.SqlFunction	CURRENT_TIMESTAMP
static org.apache.calcite.sql.SqlFunction	DATE_ADD
static org.apache.calcite.sql.SqlFunction	DATE_FORMAT
static org.apache.calcite.sql.SqlFunction	DATE_FORMAT_TZ
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.SqlBinaryOperator	DIVIDE
static org.apache.calcite.sql.SqlFunction	ELEMENT
static org.apache.calcite.sql.SqlFunction	ENDSWITH
static org.apache.calcite.sql.SqlBinaryOperator	EQUALS
static org.apache.calcite.sql.SqlFunction	EXTRACT
static org.apache.calcite.sql.SqlFunction	FLOOR
static org.apache.calcite.sql.SqlFunction	FROM_BASE64
static org.apache.calcite.sql.SqlFunction	FROM_BASE64_BINARY
static org.apache.calcite.sql.SqlFunction	FROM_UNIXTIME
static org.apache.calcite.sql.SqlFunction	GET_EMBEDDING
static org.apache.calcite.sql.SqlBinaryOperator	GREATER_THAN
static org.apache.calcite.sql.SqlBinaryOperator	GREATER_THAN_OR_EQUAL
static org.apache.calcite.sql.SqlFunction	HOUR
static org.apache.calcite.sql.SqlFunction	IF
static org.apache.calcite.sql.SqlFunction	IFNULL
static org.apache.calcite.sql.SqlBinaryOperator	IN
static org.apache.calcite.sql.SqlFunction	INSTR
static org.apache.calcite.sql.SqlBinaryOperator	IS_DISTINCT_FROM
static org.apache.calcite.sql.SqlPostfixOperator	IS_FALSE
static org.apache.calcite.sql.SqlBinaryOperator	IS_NOT_DISTINCT_FROM
static org.apache.calcite.sql.SqlPostfixOperator	IS_NOT_FALSE
static org.apache.calcite.sql.SqlPostfixOperator	IS_NOT_NULL
static org.apache.calcite.sql.SqlPostfixOperator	IS_NOT_TRUE
static org.apache.calcite.sql.SqlPostfixOperator	IS_NOT_UNKNOWN
static org.apache.calcite.sql.SqlPostfixOperator	IS_NULL
static org.apache.calcite.sql.SqlPostfixOperator	IS_TRUE
static org.apache.calcite.sql.SqlPostfixOperator	IS_UNKNOWN
static org.apache.calcite.sql.SqlOperator	ITEM
static org.apache.calcite.sql.SqlFunction	LEFT
static org.apache.calcite.sql.SqlBinaryOperator	LESS_THAN
static org.apache.calcite.sql.SqlBinaryOperator	LESS_THAN_OR_EQUAL
static org.apache.calcite.sql.SqlSpecialOperator	LIKE
static org.apache.calcite.sql.SqlFunction	LOCALTIME
static org.apache.calcite.sql.SqlFunction	LOCALTIMESTAMP
static org.apache.calcite.sql.SqlFunction	LOCATE
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
static org.apache.calcite.sql.SqlBinaryOperator	MINUS
static org.apache.calcite.sql.SqlFunction	MINUTE
static org.apache.calcite.sql.SqlFunction	MONTH
static org.apache.calcite.sql.SqlBinaryOperator	MULTIPLY
static org.apache.calcite.sql.SqlPrefixOperator	NOT
static org.apache.calcite.sql.fun.SqlBetweenOperator	NOT_BETWEEN
static org.apache.calcite.sql.SqlBinaryOperator	NOT_EQUALS
static org.apache.calcite.sql.SqlBinaryOperator	NOT_IN
static org.apache.calcite.sql.SqlSpecialOperator	NOT_LIKE
static org.apache.calcite.sql.SqlSpecialOperator	NOT_SIMILAR_TO
static org.apache.calcite.sql.SqlFunction	NOW
static org.apache.calcite.sql.SqlFunction	NULLIF
static org.apache.calcite.sql.SqlBinaryOperator	OR
static org.apache.calcite.sql.SqlFunction	OVERLAY
static org.apache.calcite.sql.SqlFunction	PARSE_JSON
static org.apache.calcite.sql.SqlBinaryOperator	PERCENT_REMAINDER
static org.apache.calcite.sql.SqlBinaryOperator	PLUS
static org.apache.calcite.sql.SqlFunction	POSITION
static org.apache.calcite.sql.SqlFunction	QUARTER
static org.apache.calcite.sql.SqlFunction	REGEXP_COUNT
static org.apache.calcite.sql.SqlFunction	REGEXP_EXTRACT
static org.apache.calcite.sql.SqlFunction	REGEXP_EXTRACT_ALL
static org.apache.calcite.sql.SqlFunction	REGEXP_INSTR
static org.apache.calcite.sql.SqlFunction	REGEXP_REPLACE
static org.apache.calcite.sql.SqlFunction	REGEXP_SUBSTR
static org.apache.calcite.sql.SqlFunction	REPEAT
static org.apache.calcite.sql.SqlFunction	REPLACE
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.SqlFunction	RPAD
static org.apache.calcite.sql.SqlFunction	RTRIM
static org.apache.calcite.sql.SqlFunction	SECOND
static org.apache.calcite.sql.SqlSpecialOperator	SIMILAR_TO
static org.apache.calcite.sql.SqlFunction	STARTSWITH
static org.apache.calcite.sql.SqlFunction	SUBSTR
static org.apache.calcite.sql.SqlFunction	SUBSTRING
static org.apache.calcite.sql.SqlFunction	TIMESTAMP_DIFF
static org.apache.calcite.sql.SqlFunction	TIMESTAMPADD
static org.apache.calcite.sql.SqlFunction	TIMESTAMPDIFF
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	TRY_CAST
static org.apache.calcite.sql.SqlFunction	TRY_PARSE_JSON
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.SqlFunction	WEEK
static org.apache.calcite.sql.SqlFunction	YEAR

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

IS_NAME

Method Summary

Modifier and Type	Method	Description
static TransformSqlOperatorTable	instance()
void	lookupOperatorOverloads(org.apache.calcite.sql.SqlIdentifier opName, org.apache.calcite.sql.SqlFunctionCategory sqlFunctionCategory, 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

EQUALS

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

NOT_EQUALS

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

IS_DISTINCT_FROM

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

IS_NOT_DISTINCT_FROM

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

GREATER_THAN

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

GREATER_THAN_OR_EQUAL

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

LESS_THAN

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

LESS_THAN_OR_EQUAL

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

IS_NULL

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

IS_NOT_NULL

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

IS_UNKNOWN

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

IS_NOT_UNKNOWN

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

BETWEEN

public static final org.apache.calcite.sql.fun.SqlBetweenOperator BETWEEN

NOT_BETWEEN

public static final org.apache.calcite.sql.fun.SqlBetweenOperator NOT_BETWEEN

LIKE

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

NOT_LIKE

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

SIMILAR_TO

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

NOT_SIMILAR_TO

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

IN

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

NOT_IN

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

OR

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

AND

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

NOT

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

IS_FALSE

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

IS_NOT_FALSE

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

IS_TRUE

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

IS_NOT_TRUE

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

PLUS

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

MINUS

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

MULTIPLY

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

DIVIDE

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

PERCENT_REMAINDER

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

ABS

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

CEIL

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

FLOOR

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

ROUND

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

UUID

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

CONCAT

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

CONCAT_FUNCTION

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

CHAR_LENGTH

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

UPPER

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

LOWER

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

TRIM

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

LTRIM

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

RTRIM

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

BTRIM

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

REGEXP_REPLACE

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

REGEXP_EXTRACT

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

REGEXP_EXTRACT_ALL

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

REGEXP_COUNT

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

REGEXP_INSTR

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

REGEXP_SUBSTR

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

SUBSTR

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

SUBSTRING

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

OVERLAY

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

POSITION

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

LOCATE

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

INSTR

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

CONCAT_WS

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

LPAD

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

RPAD

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

REPLACE

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

REPEAT

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

LEFT

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

RIGHT

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

STARTSWITH

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

ENDSWITH

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

TO_BASE64

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

FROM_BASE64

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

FROM_BASE64_BINARY

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

EXTRACT

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

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

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

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

LOCALTIME

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

LOCALTIMESTAMP

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

CURRENT_TIME

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

CURRENT_DATE

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

CURRENT_TIMESTAMP

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

NOW

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

UNIX_TIMESTAMP

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

FROM_UNIXTIME

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

DATE_FORMAT

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

TIMESTAMP_DIFF

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

TIMESTAMPDIFF

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

TIMESTAMPADD

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

TO_DATE

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

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

DATE_FORMAT_TZ

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

DATE_ADD

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

CASE

public static final org.apache.calcite.sql.fun.SqlCaseOperator CASE

COALESCE

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

NULLIF

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

IFNULL

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

IF

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

CAST

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

TRY_CAST

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

ARRAY

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

MAP

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

ROW

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

ITEM

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

CARDINALITY

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

ELEMENT

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

ARRAY_CONTAINS

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

ARRAY_POSITION

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

AI_CHAT_PREDICT

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

GET_EMBEDDING

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

AI_LANGCHAIN_PREDICT

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

PARSE_JSON

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

TRY_PARSE_JSON

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

Method Detail

instance

public static TransformSqlOperatorTable instance()

lookupOperatorOverloads

public void lookupOperatorOverloads(org.apache.calcite.sql.SqlIdentifier opName,
                                    @Nullable
                                    org.apache.calcite.sql.SqlFunctionCategory sqlFunctionCategory,
                                    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