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 0aae16f45d [INLONG-11092][SDK] Fix the issue of inconsistent
capitalization of Function names in FunctionalTools (#11093)
add af9acab33e [INLONG-11018][SDK] Transform SQL supports COMPRESS and
UNCOMPRESS Functions (#11048)
No new revisions were added by this update.
Summary of changes:
.../process/function/CompressFunction.java | 117 +++++++++++++++++++++
.../process/function/UnCompressFunction.java | 100 ++++++++++++++++++
.../factory/CompressionAlgorithmFactory.java} | 34 +++---
.../factory/UnCompressionAlgorithmFactory.java} | 34 +++---
.../process/function/handler/CompressHandler.java | 10 +-
.../process/function/handler/DeflaterCompress.java | 39 +++----
.../function/handler/DeflaterUncompress.java | 37 +++----
.../process/function/handler/GzipCompress.java | 24 ++---
.../process/function/handler/GzipUncompress.java | 38 +++----
.../function/handler/UncompressHandler.java | 7 +-
.../process/function/handler/ZipCompress.java | 38 +++----
.../process/function/handler/ZipUncompress.java | 43 ++++++++
...ngthFunction.java => TestCompressFunction.java} | 42 +++++---
.../function/string/TestUnCompressFunction.java | 110 +++++++++++++++++++
14 files changed, 500 insertions(+), 173 deletions(-)
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/CompressFunction.java
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/UnCompressFunction.java
copy
inlong-sdk/{dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/ConcurrentHashSet.java
=>
transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/factory/CompressionAlgorithmFactory.java}
(51%)
copy
inlong-sdk/{dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/ConcurrentHashSet.java
=>
transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/factory/UnCompressionAlgorithmFactory.java}
(50%)
copy
inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/AuthenticationType.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/CompressHandler.java
(84%)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/field/format/ByteTypeInfo.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/DeflaterCompress.java
(54%)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/field/format/ByteTypeInfo.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/DeflaterUncompress.java
(55%)
copy
inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/FlinkSortPollerPlugin.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/GzipCompress.java
(62%)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/field/format/IntTypeInfo.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/GzipUncompress.java
(53%)
copy
inlong-agent/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/task/MockInstanceManager.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/UncompressHandler.java
(83%)
copy
inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/field/format/IntTypeInfo.java
=>
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/ZipCompress.java
(56%)
create mode 100644
inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/handler/ZipUncompress.java
copy
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/string/{TestBitLengthFunction.java
=> TestCompressFunction.java} (62%)
create mode 100644
inlong-sdk/transform-sdk/src/test/java/org/apache/inlong/sdk/transform/process/function/string/TestUnCompressFunction.java
