ying-hua opened a new pull request, #11082:
URL: https://github.com/apache/inlong/pull/11082
Fixes #11030
### Motivation
Transform add avro source data. Currently, the transform supports parsing
Avro data types including int, float, long double, string, bool
luchunliang commented on code in PR #11078:
URL: https://github.com/apache/inlong/pull/11078#discussion_r1754107629
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/NullIfFunction.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache
Zkplo commented on code in PR #11078:
URL: https://github.com/apache/inlong/pull/11078#discussion_r1754194450
##
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/NullIfFunction.java:
##
@@ -0,0 +1,63 @@
+/*
+ * Licensed to the Apache Softwa
emptyOVO closed pull request #11083: [INLONG-10287][Agent] Update the Redis
Source
URL: https://github.com/apache/inlong/pull/11083
--
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 comme
emptyOVO opened a new pull request, #11083:
URL: https://github.com/apache/inlong/pull/11083
Fixes #10287
### Motivation
this pull request is a enhancement of the previous pr #10801
Complete the task requirement mentioned in pr #10801
* Two modes are provide
emptyOVO opened a new pull request, #11084:
URL: https://github.com/apache/inlong/pull/11084
Fixes #10287
### Motivation
this pull request is a enhancement of the previous pr #10801
Complete the task requirement mentioned in pr #10801
* Two modes are provide
emptyOVO opened a new pull request, #11085:
URL: https://github.com/apache/inlong/pull/11085
Fixes #11005
### Motivation
add YamlSourceData, YamlSourceDecoder, YamlSourceInfo, provide unit tests
### Modifications
### Verifying this change
aloyszhang commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756081633
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Softwar
aloyszhang commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756081863
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Softwar
justinwwhuang commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756095808
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -17,54 +17,279 @@
package org.apache.inlong.agent.p
justinwwhuang commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756099335
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -17,54 +17,279 @@
package org.apache.inlong.agent.p
justinwwhuang commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756102202
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
@O
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756120543
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
@O
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756136763
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756137158
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -17,54 +17,279 @@
package org.apache.inlong.agent.plugin
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756138334
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -17,54 +17,279 @@
package org.apache.inlong.agent.plugin
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756145612
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
@O
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756154385
##
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java:
##
@@ -0,0 +1,261 @@
+/*
+ * Licensed to the Apache Software
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756115922
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
@O
emptyOVO commented on code in PR #11084:
URL: https://github.com/apache/inlong/pull/11084#discussion_r1756120543
##
inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java:
##
@@ -84,6 +321,272 @@ public boolean sourceFinish() {
@O
Zkplo opened a new pull request, #11086:
URL: https://github.com/apache/inlong/pull/11086
Fixes #11081
### Motivation
Based on
[Mysql](https://dev.mysql.com/doc/refman/8.4/en/expressions.html#temporal-intervals):
1. Added IntervalParser class
```
Inter
dockerzhang merged PR #11052:
URL: https://github.com/apache/inlong/pull/11052
--
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
This is an automated email from the ASF dual-hosted git repository.
dockerzhang 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 4cdce2c585 [INLONG-11044][SDK] Transform SQ
dockerzhang merged PR #11078:
URL: https://github.com/apache/inlong/pull/11078
--
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
This is an automated email from the ASF dual-hosted git repository.
dockerzhang 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 2af7480220 [INLONG-11064][SDK] Transform SQ
dockerzhang commented on PR #11001:
URL: https://github.com/apache/inlong/pull/11001#issuecomment-2345413366
@Zkplo please fix the failed workflows and UTs.
--
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
dockerzhang merged PR #10994:
URL: https://github.com/apache/inlong/pull/10994
--
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
This is an automated email from the ASF dual-hosted git repository.
dockerzhang 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 e33a5e8816 [INLONG-10882][SDK] Transform SQ
30 matches
Mail list logo
