This is an automated email from the ASF dual-hosted git repository.
aloyszhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from cba6abd8a0 [INLONG-10714][Manager] Fix the problem of incorrect
deletion of data source task (#10715)
add a4e688171d [INLONG-10716][SDK] Inlong Transform usage optimization
(#10717)
No new revisions were added by this update.
Summary of changes:
.../common/pojo/sort/dataflow/DataFlowConfig.java | 1 +
.../pojo/sort/dataflow/dataType/CsvConfig.java | 2 +-
.../pojo/sort/dataflow/dataType/KvConfig.java | 4 +-
.../sdk/transform/decode/CsvSourceDecoder.java | 8 +--
.../sdk/transform/decode/KvSourceDecoder.java | 24 ++++++++-
.../sdk/transform/encode/CsvSinkEncoder.java | 8 +--
.../inlong/sdk/transform/encode/KvSinkEncoder.java | 12 ++++-
.../inlong/sdk/transform/pojo/CsvSinkInfo.java | 16 +++---
.../inlong/sdk/transform/pojo/CsvSourceInfo.java | 18 ++++---
.../inlong/sdk/transform/pojo/KvSinkInfo.java | 6 +++
.../inlong/sdk/transform/pojo/KvSourceInfo.java | 9 ++++
.../apache/inlong/sdk/transform/pojo/SinkInfo.java | 2 +
.../inlong/sdk/transform/pojo/SourceInfo.java | 2 +
.../inlong/sdk/transform/process/Context.java | 8 +++
.../transform/process/operator/OperatorTools.java | 4 ++
.../TestTransformArithmeticFunctionsProcessor.java | 2 +-
.../transform/process/TestTransformProcessor.java | 22 ++++----
.../sort-standalone-source/pom.xml | 5 ++
.../inlong/sort/standalone/sink/SinkContext.java | 61 ++++++++++++++++++++++
19 files changed, 172 insertions(+), 42 deletions(-)
