This is an automated email from the ASF dual-hosted git repository.
aloyszhang 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 4de972e932 [INLONG-10942][SDK] Add official function names for all
Transform functions (#10943)
4de972e932 is described below
commit 4de972e9324f443ab3c71f88b5c43f93c9825ee6
Author: Zkplo <87751516+zk...@users.noreply.github.com>
AuthorDate: Mon Sep 2 14:28:32 2024 +0800
[INLONG-10942][SDK] Add official function names for all Transform functions
(#10943)
---
.../inlong/sdk/transform/process/function/DateExtractFunction.java | 6 +++---
.../inlong/sdk/transform/process/function/FromUnixTimeFunction.java | 2 +-
.../inlong/sdk/transform/process/function/SubstringFunction.java | 4 +++-
.../inlong/sdk/transform/process/function/TimestampAddFunction.java | 2 +-
4 files changed, 8 insertions(+), 6 deletions(-)
diff --git
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateExtractFunction.java
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateExtractFunction.java
index cac2273619..a1ab7e2dfa 100644
---
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateExtractFunction.java
+++
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DateExtractFunction.java
@@ -86,7 +86,7 @@ public abstract class DateExtractFunction implements
ValueParser {
}
}
- @TransformFunction(names = {"day_of_year"})
+ @TransformFunction(names = {"day_of_year", "dayofyear"})
public static class DayOfYearExtractFunction extends DateExtractFunction {
public DayOfYearExtractFunction(Function expr) {
@@ -94,7 +94,7 @@ public abstract class DateExtractFunction implements
ValueParser {
}
}
- @TransformFunction(names = {"day_of_month"})
+ @TransformFunction(names = {"day_of_month", "dayofmonth"})
public static class DayOfMonthExtractFunction extends DateExtractFunction {
public DayOfMonthExtractFunction(Function expr) {
@@ -102,7 +102,7 @@ public abstract class DateExtractFunction implements
ValueParser {
}
}
- @TransformFunction(names = {"day_of_week"})
+ @TransformFunction(names = {"day_of_week", "dayofweek"})
public static class DayOfWeekExtractFunction extends DateExtractFunction {
public DayOfWeekExtractFunction(Function expr) {
diff --git
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FromUnixTimeFunction.java
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FromUnixTimeFunction.java
index b7b68a0e73..6a897ee3e0 100644
---
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FromUnixTimeFunction.java
+++
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/FromUnixTimeFunction.java
@@ -41,7 +41,7 @@ import java.util.concurrent.ConcurrentHashMap;
* format(default is ‘yyyy-MM-dd HH:mm:ss’). numeric is an internal timestamp
value representing seconds
* since ‘1970-01-01 00:00:00’ UTC, such as produced by the UNIX_TIMESTAMP()
function.
*/
-@TransformFunction(names = {"from_unix_time"})
+@TransformFunction(names = {"from_unix_time", "form_unixtime"})
public class FromUnixTimeFunction implements ValueParser {
private ValueParser numericParser;
diff --git
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/SubstringFunction.java
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/SubstringFunction.java
index 772dc2950c..727c0484b4 100644
---
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/SubstringFunction.java
+++
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/SubstringFunction.java
@@ -32,7 +32,7 @@ import java.util.List;
* description: substring(string FROM INT1 [ FOR INT2 ])--returns a substring
of STRING starting from position INT1 with
* length INT2 (to the end by default)
*/
-@TransformFunction(names = {"substring"})
+@TransformFunction(names = {"substring", "substr"})
public class SubstringFunction implements ValueParser {
private ValueParser stringParser;
@@ -41,6 +41,7 @@ public class SubstringFunction implements ValueParser {
/**
* Constructor
+ *
* @param expr
*/
public SubstringFunction(Function expr) {
@@ -55,6 +56,7 @@ public class SubstringFunction implements ValueParser {
/**
* parse
+ *
* @param sourceData
* @param rowIndex
* @return
diff --git
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TimestampAddFunction.java
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TimestampAddFunction.java
index 9bcbb8c8e4..29b4636d81 100644
---
a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TimestampAddFunction.java
+++
b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TimestampAddFunction.java
@@ -36,7 +36,7 @@ import java.util.List;
* The unit of the time interval is specified by the unit parameter, which
should be one of the following values:
* FRAC_SECOND, SECOND, MINUTE, HOUR, DAY, WEEK, MONTH, QUARTER, or YEAR.
*/
-@TransformFunction(names = {"timestamp_add"})
+@TransformFunction(names = {"timestamp_add", "timestampadd"})
public class TimestampAddFunction implements ValueParser {
private ValueParser intervalParser;
