This is an automated email from the ASF dual-hosted git repository.
luchunliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
The following commit(s) were added to refs/heads/master by this push:
new 578faa15cb [INLONG-12158][SDK] Support SQL reserved keywords as source
field names (backtick-quoted columns) (#12159)
578faa15cb is described below
commit 578faa15cb00db8fef3bcf6ffbe3d3ea2fc3d65e
Author: ChunLiang Lu <[email protected]>
AuthorDate: Sun Jul 12 12:05:56 2026 +0800
[INLONG-12158][SDK] Support SQL reserved keywords as source field names
(backtick-quoted columns) (#12159)
---
.../inlong/sdk/transform/process/parser/ColumnParser.java | 14 ++++++++++++--
1 file changed, 12 insertions(+), 2 deletions(-)
diff --git
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ColumnParser.java
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ColumnParser.java
index 7102b3c969..847e5cb5f4 100644
---
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ColumnParser.java
+++
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/parser/ColumnParser.java
@@ -33,13 +33,23 @@ public class ColumnParser implements ValueParser {
private final String fieldName;
public ColumnParser(Column expr) {
- this.fieldName = expr.toString();
+ this.fieldName = this.formatFieldName(expr.toString());
}
public ColumnParser(Function expr) {
- this.fieldName = expr.toString();
+ this.fieldName = this.formatFieldName(expr.toString());
}
+ private String formatFieldName(String rawFieldName) {
+ String tmpFieldName = rawFieldName;
+ if (tmpFieldName.startsWith("`")) {
+ tmpFieldName = tmpFieldName.substring(1);
+ }
+ if (tmpFieldName.endsWith("`")) {
+ tmpFieldName = tmpFieldName.substring(0, tmpFieldName.length() -
1);
+ }
+ return tmpFieldName;
+ }
/**
* parse
* @param sourceData
