This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 714d7af5b6 [INLONG-10109][SDK] Support to transform from Json protocol
to CSV/KV protocol by single SQL (#10110)
add c4cac2e981 [INLONG-10117][SDK] Support to transform from PB protocol
to CSV/KV protocol by single SQL (#10127)
No new revisions were added by this update.
Summary of changes:
inlong-sdk/transform-sdk/pom.xml | 5 +
.../inlong/sdk/transform/decode/JsonNode.java | 4 +-
.../apache/inlong/sdk/transform/decode/PbNode.java | 95 ++++++++
.../inlong/sdk/transform/decode/PbSourceData.java | 240 +++++++++++++++++++++
.../sdk/transform/decode/PbSourceDecoder.java | 165 ++++++++++++++
.../sdk/transform/decode/TransformException.java} | 29 +--
.../inlong/sdk/transform/pojo/PbSourceInfo.java | 44 ++--
.../sdk/transform/process/TransformProcessor.java | 4 +
.../sdk/transform/process/parser/ColumnParser.java | 2 +-
.../sdk/transform/pojo/TestTransformConfig.java | 7 +-
.../transform/process/TestTransformProcessor.java | 117 +++++++---
11 files changed, 652 insertions(+), 60 deletions(-)
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/PbNode.java
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/PbSourceData.java
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/PbSourceDecoder.java
copy
inlong-sdk/{dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/pb/config/pojo/ErrorCode.java
=>
transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/TransformException.java}
(70%)
