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
