Mao Jiayi created FLINK-40223:
---------------------------------
Summary: Support additional Flink SQL string functions in YAML
Transform
Key: FLINK-40223
URL: https://issues.apache.org/jira/browse/FLINK-40223
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: Mao Jiayi
Flink CDC YAML Transform currently provides only a basic set of string
functions, such as CONCAT, CHAR_LENGTH, UPPER, LOWER, TRIM, SUBSTRING, and
REGEXP_REPLACE.
Many commonly used Flink SQL string functions are still unavailable. As a
result, users may need to implement UDFs or preprocess data for string
operations that can be expressed directly in Flink SQL.
The missing functions include:
* OVERLAY, POSITION, INSTR, and LOCATE
* LTRIM, RTRIM, and BTRIM
* CONCAT_WS, LPAD, and RPAD
* REPLACE, REPEAT, LEFT, and RIGHT
* STARTSWITH and ENDSWITH
* TO_BASE64 and FROM_BASE64
YAML Transform should support these functions with argument validation, return
types, NULL handling, and edge-case behavior aligned with Flink SQL.
This would improve compatibility between Flink SQL and row-level YAML Transform
expressions without changing the behavior of existing functions.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
