Re: [PR] [INLONG-11008][SDK] Transform SQL support PRINTF function. [inlong]

2024-09-09 Thread via GitHub
Ybsiz commented on code in PR #11032: URL: https://github.com/apache/inlong/pull/11032#discussion_r1751268316 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/PrintfFunction.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache So

Re: [PR] [INLONG-11072][Sort] Optimize EsSink when transform processor is null [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #11073: URL: https://github.com/apache/inlong/pull/11073 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

[PR] [INLONG-11074][Sort] Transform support dummy select when the transform sql is empty [inlong]

2024-09-09 Thread via GitHub
vernedeng opened a new pull request, #11075: URL: https://github.com/apache/inlong/pull/11075 Fixes #11074 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [

[PR] [INLONG-11072][Sort] Optimize EsSink when transform processor is null [inlong]

2024-09-09 Thread via GitHub
vernedeng opened a new pull request, #11073: URL: https://github.com/apache/inlong/pull/11073 Fixes #11072 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This c

(inlong) branch master updated: [INLONG-10900][SDK] Transform SQL support soundex function (#11061)

2024-09-09 Thread aloyszhang
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 9ec6785c63 [INLONG-10900][SDK] Transform SQL

Re: [PR] [INLONG-10900][SDK] Transform SQL support soundex function [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #11061: URL: https://github.com/apache/inlong/pull/11061 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

(inlong) branch master updated (6104e21984 -> 8588d6ceaa)

2024-09-09 Thread aloyszhang
This is an automated email from the ASF dual-hosted git repository. aloyszhang pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/inlong.git from 6104e21984 [INLONG-10938][SDK] Transform SQL supports fuzzy matching of LIKE and NOT LIKE (#11009) add 8588d

(inlong) branch master updated: [INLONG-10938][SDK] Transform SQL supports fuzzy matching of LIKE and NOT LIKE (#11009)

2024-09-09 Thread aloyszhang
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 6104e21984 [INLONG-10938][SDK] Transform SQL

Re: [PR] [INLONG-10938][SDK] Transform SQL supports fuzzy matching of LIKE and NOT LIKE [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #11009: URL: https://github.com/apache/inlong/pull/11009 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

Re: [PR] [INLONG-10986][SDK] Transform support REGEXP_MATCHES(str, pattern) function [inlong]

2024-09-09 Thread via GitHub
dockerzhang merged PR #10993: URL: https://github.com/apache/inlong/pull/10993 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlon

Re: [PR] [INLONG-11012][SDK] Transform SQL supports LCASE and UCASE Functions [inlong]

2024-09-09 Thread via GitHub
dockerzhang merged PR #11024: URL: https://github.com/apache/inlong/pull/11024 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlon

Re: [PR] [INLONG-11044][SDK] Transform SQL supports string judgment functions(IS_ALPHA、IS_DECIMAL、IS_DIGIT) [inlong]

2024-09-09 Thread via GitHub
Zkplo commented on code in PR #11052: URL: https://github.com/apache/inlong/pull/11052#discussion_r1751153563 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/IsDecimalFunction.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed to the Apache Sof

Re: [PR] [INLONG-11050][SDK] Transform SQL supports bit_length Function [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #11055: URL: https://github.com/apache/inlong/pull/11055 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

Re: [PR] [INLONG-11057][SDK] Transform support E() function [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #11062: URL: https://github.com/apache/inlong/pull/11062 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

Re: [PR] [INLONG-11037][SDK] Transform support ENCODE() and DECODE() function [inlong]

2024-09-09 Thread via GitHub
emptyOVO commented on code in PR #11041: URL: https://github.com/apache/inlong/pull/11041#discussion_r1750476465 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/DecodeFunction.java: ## @@ -0,0 +1,90 @@ +/* + * Licensed to the Apache Sof

Re: [PR] [INLONG-11035][SDK] Transform support TRUNCATE() function [inlong]

2024-09-09 Thread via GitHub
emptyOVO commented on code in PR #11040: URL: https://github.com/apache/inlong/pull/11040#discussion_r1750468240 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TruncateFunction.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apache S

Re: [PR] [INLONG-11018][SDK] Transform SQL supports COMPRESS and UNCOMPRESS Functions [inlong]

2024-09-09 Thread via GitHub
vernedeng commented on code in PR #11048: URL: https://github.com/apache/inlong/pull/11048#discussion_r1750431867 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UnCompressFunction.java: ## @@ -0,0 +1,88 @@ +/* + * Licensed to the Apach

Re: [PR] [INLONG-11018][SDK] Transform SQL supports COMPRESS and UNCOMPRESS Functions [inlong]

2024-09-09 Thread via GitHub
vernedeng commented on code in PR #11048: URL: https://github.com/apache/inlong/pull/11048#discussion_r1750430979 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/CompressFunction.java: ## @@ -0,0 +1,105 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-11044][SDK] Transform SQL supports string judgment functions(IS_ALPHA、IS_DECIMAL、IS_DIGIT) [inlong]

2024-09-09 Thread via GitHub
vernedeng commented on code in PR #11052: URL: https://github.com/apache/inlong/pull/11052#discussion_r1750420622 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/IsDecimalFunction.java: ## @@ -0,0 +1,61 @@ +/* + * Licensed to the Apache

Re: [PR] [INLONG-11056][SDK] Transform support RAND_INTEGER() function [inlong]

2024-09-09 Thread via GitHub
emptyOVO commented on code in PR #11063: URL: https://github.com/apache/inlong/pull/11063#discussion_r1750407219 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RandIntegerFunction.java: ## @@ -0,0 +1,76 @@ +/* + * Licensed to the Apach

[PR] [INLONG-11068][Sort] Optimize kafka producer parameters [inlong]

2024-09-09 Thread via GitHub
vernedeng opened a new pull request, #11069: URL: https://github.com/apache/inlong/pull/11069 Fixes #11068 ### Motivation ### Modifications ### Verifying this change *(Please pick either of the following options)* - [ ] This

Re: [PR] [INLONG-11065][Sort] Provides a method to add openTelemetryAppender for the sort connector [inlong]

2024-09-09 Thread via GitHub
qy-liuhuo commented on PR #11066: URL: https://github.com/apache/inlong/pull/11066#issuecomment-2338207539 Just use it like this: ```java import org.apache.inlong.sort.base.util.OpenTelemetryLogger; public class XXXSourceReader { private static final Logger LOG = L

Re: [PR] [INLONG-11013][Sort] A demo of reporting sort logs through OpenTelemetry [inlong]

2024-09-09 Thread via GitHub
qy-liuhuo commented on code in PR #11015: URL: https://github.com/apache/inlong/pull/11015#discussion_r1750271810 ## inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/reader/MySqlSourceReader.java: ## @@ -88,6 +95

[PR] [INLONG-11065][Sort] Provides a method to add openTelemetryAppender for the sort connector [inlong]

2024-09-09 Thread via GitHub
qy-liuhuo opened a new pull request, #11066: URL: https://github.com/apache/inlong/pull/11066 In order to more conveniently view the log output, using OpenTelemetry to achieve centralized log reporting - Fixes #11065 ### Motivation In order to more c

Re: [PR] [INLONG-11008][SDK] Transform SQL support PRINTF function. [inlong]

2024-09-09 Thread via GitHub
aloyszhang commented on code in PR #11032: URL: https://github.com/apache/inlong/pull/11032#discussion_r1750190796 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/PrintfFunction.java: ## @@ -0,0 +1,78 @@ +/* + * Licensed to the Apache S

Re: [PR] [INLONG-11028][SDK] Transform SQL support UrlEncode & UrlDecode functions [inlong]

2024-09-09 Thread via GitHub
aloyszhang commented on code in PR #11031: URL: https://github.com/apache/inlong/pull/11031#discussion_r1750185615 ## inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UrlEncodeFunction.java: ## @@ -0,0 +1,71 @@ +/* + * Licensed to the Apach

Re: [PR] [INLONG-10881][SDK] Transform SQL support concat_ws function [inlong]

2024-09-09 Thread via GitHub
aloyszhang merged PR #10992: URL: https://github.com/apache/inlong/pull/10992 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@inlong

Re: [PR] [INLONG-11057][SDK] Transform support E() function [inlong]

2024-09-09 Thread via GitHub
aloyszhang commented on code in PR #11062: URL: https://github.com/apache/inlong/pull/11062#discussion_r1750153039 ## inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/arithmetic/TestEFunction.java: ## @@ -0,0 +1,45 @@ +/* + * Licensed to th