You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@inlong.apache.org by lu...@apache.org on 2024/09/19 03:19:31 UTC

(inlong) branch master updated (9731701558 -> 03a27a75b3)

This is an automated email from the ASF dual-hosted git repository.

luchunliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from 9731701558 [INLONG-11122][SDK] Transform SQL supports UNHEX function (#11131)
     add 03a27a75b3 [INLONG-11020][SDK] Add BSON formatted data source for Transform (#11136)

No new revisions were added by this update.

Summary of changes:
 inlong-sdk/transform-sdk/pom.xml                   |   4 +
 .../{SourceDecoder.java => BsonSourceData.java}    |  14 +-
 .../sdk/transform/decode/BsonSourceDecoder.java    |  64 ++++++++++
 .../sdk/transform/decode/SourceDecoderFactory.java |   4 +
 .../{JsonSourceInfo.java => BsonSourceInfo.java}   |  28 +---
 .../process/processor/TestBson2CsvProcessor.java   | 141 +++++++++++++++++++++
 pom.xml                                            |   7 +
 7 files changed, 231 insertions(+), 31 deletions(-)
 copy inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/{SourceDecoder.java => BsonSourceData.java} (77%)
 create mode 100644 inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/BsonSourceDecoder.java
 copy inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/{JsonSourceInfo.java => BsonSourceInfo.java} (68%)
 create mode 100644 inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/processor/TestBson2CsvProcessor.java