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 7845da55c0 [INLONG-11233][SDK] Transform SQL supports mid function
(#11234)
add 857d4b4499 [INLONG-11252][SDK] Transform support PB sink data (#11280)
No new revisions were added by this update.
Summary of changes:
.../inlong/sdk/transform/encode/PbSinkEncoder.java | 115 +++++++++++++++
.../sdk/transform/encode/SinkEncoderFactory.java | 6 +
.../pojo/{KvSourceInfo.java => PbSinkInfo.java} | 44 +++---
.../apache/inlong/sdk/transform/pojo/SinkInfo.java | 1 +
.../process/processor/TestAny2PbProcessor.java | 157 +++++++++++++++++++++
5 files changed, 305 insertions(+), 18 deletions(-)
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/PbSinkEncoder.java
copy
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/{KvSourceInfo.java
=> PbSinkInfo.java} (63%)
create mode 100644
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/processor/TestAny2PbProcessor.java
