in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/DirectConvertRule.java [101:322]
void initNonDynamicFunctions() {
// logic functions
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.AND, FlinkSqlOperatorTable.AND);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.OR, FlinkSqlOperatorTable.OR);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.NOT, FlinkSqlOperatorTable.NOT);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.IF, FlinkSqlOperatorTable.CASE);
// comparison functions
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.EQUALS, FlinkSqlOperatorTable.EQUALS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.GREATER_THAN, FlinkSqlOperatorTable.GREATER_THAN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.GREATER_THAN_OR_EQUAL,
FlinkSqlOperatorTable.GREATER_THAN_OR_EQUAL);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LESS_THAN, FlinkSqlOperatorTable.LESS_THAN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LESS_THAN_OR_EQUAL,
FlinkSqlOperatorTable.LESS_THAN_OR_EQUAL);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.NOT_EQUALS, FlinkSqlOperatorTable.NOT_EQUALS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_NULL, FlinkSqlOperatorTable.IS_NULL);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_NOT_NULL, FlinkSqlOperatorTable.IS_NOT_NULL);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_TRUE, FlinkSqlOperatorTable.IS_TRUE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_FALSE, FlinkSqlOperatorTable.IS_FALSE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_NOT_TRUE, FlinkSqlOperatorTable.IS_NOT_TRUE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.IS_NOT_FALSE, FlinkSqlOperatorTable.IS_NOT_FALSE);
// string functions
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CHAR_LENGTH, FlinkSqlOperatorTable.CHAR_LENGTH);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.INIT_CAP, FlinkSqlOperatorTable.INITCAP);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LIKE, FlinkSqlOperatorTable.LIKE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LOWER, FlinkSqlOperatorTable.LOWER);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LOWERCASE, FlinkSqlOperatorTable.LOWER);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SIMILAR, FlinkSqlOperatorTable.SIMILAR_TO);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SUBSTRING, FlinkSqlOperatorTable.SUBSTRING);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SUBSTR, FlinkSqlOperatorTable.SUBSTR);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.UPPER, FlinkSqlOperatorTable.UPPER);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.UPPERCASE, FlinkSqlOperatorTable.UPPER);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.POSITION, FlinkSqlOperatorTable.POSITION);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.OVERLAY, FlinkSqlOperatorTable.OVERLAY);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CONCAT, FlinkSqlOperatorTable.CONCAT_FUNCTION);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CONCAT_WS, FlinkSqlOperatorTable.CONCAT_WS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LPAD, FlinkSqlOperatorTable.LPAD);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RPAD, FlinkSqlOperatorTable.RPAD);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.REGEXP_EXTRACT, FlinkSqlOperatorTable.REGEXP_EXTRACT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.FROM_BASE64, FlinkSqlOperatorTable.FROM_BASE64);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TO_BASE64, FlinkSqlOperatorTable.TO_BASE64);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ASCII, FlinkSqlOperatorTable.ASCII);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.CHR, FlinkSqlOperatorTable.CHR);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.DECODE, FlinkSqlOperatorTable.DECODE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ENCODE, FlinkSqlOperatorTable.ENCODE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LEFT, FlinkSqlOperatorTable.LEFT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RIGHT, FlinkSqlOperatorTable.RIGHT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.INSTR, FlinkSqlOperatorTable.INSTR);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LOCATE, FlinkSqlOperatorTable.LOCATE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.PARSE_URL, FlinkSqlOperatorTable.PARSE_URL);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.UUID, FlinkSqlOperatorTable.UUID);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LTRIM, FlinkSqlOperatorTable.LTRIM);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RTRIM, FlinkSqlOperatorTable.RTRIM);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.REPEAT, FlinkSqlOperatorTable.REPEAT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.REGEXP, FlinkSqlOperatorTable.REGEXP);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.REGEXP_REPLACE, FlinkSqlOperatorTable.REGEXP_REPLACE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.REVERSE, FlinkSqlOperatorTable.REVERSE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SPLIT_INDEX, FlinkSqlOperatorTable.SPLIT_INDEX);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.STR_TO_MAP, FlinkSqlOperatorTable.STR_TO_MAP);
// math functions
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.MINUS, FlinkSqlOperatorTable.MINUS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.DIVIDE, FlinkSqlOperatorTable.DIVIDE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TIMES, FlinkSqlOperatorTable.MULTIPLY);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.FLOOR, FlinkSqlOperatorTable.FLOOR);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CEIL, FlinkSqlOperatorTable.CEIL);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.ABS, FlinkSqlOperatorTable.ABS);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.EXP, FlinkSqlOperatorTable.EXP);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LOG10, FlinkSqlOperatorTable.LOG10);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.LOG2, FlinkSqlOperatorTable.LOG2);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.LN, FlinkSqlOperatorTable.LN);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.LOG, FlinkSqlOperatorTable.LOG);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.POWER, FlinkSqlOperatorTable.POWER);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.MOD, FlinkSqlOperatorTable.MOD);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.MINUS_PREFIX, FlinkSqlOperatorTable.UNARY_MINUS);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.SIN, FlinkSqlOperatorTable.SIN);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.COS, FlinkSqlOperatorTable.COS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SINH, FlinkSqlOperatorTable.SINH);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.TAN, FlinkSqlOperatorTable.TAN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TANH, FlinkSqlOperatorTable.TANH);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.COT, FlinkSqlOperatorTable.COT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ASIN, FlinkSqlOperatorTable.ASIN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ACOS, FlinkSqlOperatorTable.ACOS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ATAN, FlinkSqlOperatorTable.ATAN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ATAN2, FlinkSqlOperatorTable.ATAN2);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.COSH, FlinkSqlOperatorTable.COSH);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.DEGREES, FlinkSqlOperatorTable.DEGREES);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RADIANS, FlinkSqlOperatorTable.RADIANS);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SIGN, FlinkSqlOperatorTable.SIGN);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ROUND, FlinkSqlOperatorTable.ROUND);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.PI, FlinkSqlOperatorTable.PI);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.E, FlinkSqlOperatorTable.E);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RAND, FlinkSqlOperatorTable.RAND);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.RAND_INTEGER, FlinkSqlOperatorTable.RAND_INTEGER);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.BIN, FlinkSqlOperatorTable.BIN);
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.HEX, FlinkSqlOperatorTable.HEX);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TRUNCATE, FlinkSqlOperatorTable.TRUNCATE);
// time functions
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.EXTRACT, FlinkSqlOperatorTable.EXTRACT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CURRENT_ROW_TIMESTAMP,
FlinkSqlOperatorTable.CURRENT_ROW_TIMESTAMP);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.DATE_FORMAT, FlinkSqlOperatorTable.DATE_FORMAT);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CONVERT_TZ, FlinkSqlOperatorTable.CONVERT_TZ);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.FROM_UNIXTIME, FlinkSqlOperatorTable.FROM_UNIXTIME);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.UNIX_TIMESTAMP, FlinkSqlOperatorTable.UNIX_TIMESTAMP);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TO_DATE, FlinkSqlOperatorTable.TO_DATE);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.TO_TIMESTAMP, FlinkSqlOperatorTable.TO_TIMESTAMP);
// catalog functions
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CURRENT_DATABASE,
FlinkSqlOperatorTable.CURRENT_DATABASE);
// collection
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.AT, FlinkSqlOperatorTable.ITEM);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.CARDINALITY, FlinkSqlOperatorTable.CARDINALITY);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ORDER_DESC, FlinkSqlOperatorTable.DESC);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.ARRAY_ELEMENT, FlinkSqlOperatorTable.ELEMENT);
// crypto hash
definitionSqlOperatorHashMap.put(BuiltInFunctionDefinitions.MD5, FlinkSqlOperatorTable.MD5);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA2, FlinkSqlOperatorTable.SHA2);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA224, FlinkSqlOperatorTable.SHA224);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA256, FlinkSqlOperatorTable.SHA256);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA384, FlinkSqlOperatorTable.SHA384);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA512, FlinkSqlOperatorTable.SHA512);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.SHA1, FlinkSqlOperatorTable.SHA1);
definitionSqlOperatorHashMap.put(
BuiltInFunctionDefinitions.STREAM_RECORD_TIMESTAMP,
FlinkSqlOperatorTable.STREAMRECORD_TIMESTAMP);
}