This is an automated email from the ASF dual-hosted git repository.
dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from e7b0170f5 [INLONG-5391][Dashboard] Unified consumption
creation/management logic (#5392)
add 0d0f2e2f0 [INLONG-5387][Manager][Sort] Support encrypt records (#5388)
No new revisions were added by this update.
Summary of changes:
.../inlong/manager/common/enums/TransformType.java | 7 +-
.../manager/pojo/sort/util/FieldRelationUtils.java | 46 +++++
.../pojo/sort/util/FilterFunctionUtils.java | 2 +
.../manager/pojo/sort/util/StreamParseUtils.java | 3 +
.../EncryptDefinition.java} | 35 ++--
.../pojo/transform/TransformDefinitionTest.java | 20 +++
.../protocol/transformation/FunctionParam.java | 4 +-
...xpReplaceFunction.java => EncryptFunction.java} | 49 +++---
.../inlong/sort/function/EncryptFunction.java | 195 +++++++++++++++++++++
.../inlong/sort/parser/impl/FlinkSqlParser.java | 2 +
.../sort/parser/impl/NativeFlinkSqlParser.java | 2 +
...tFunctionTest.java => EncryptFunctionTest.java} | 38 ++--
12 files changed, 332 insertions(+), 71 deletions(-)
copy
inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/transform/{replacer/StringReplacerDefinition.java
=> encrypt/EncryptDefinition.java} (59%)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/function/{RegexpReplaceFunction.java
=> EncryptFunction.java} (65%)
create mode 100644
inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java
copy
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/function/{RegexpReplaceFirstFunctionTest.java
=> EncryptFunctionTest.java} (78%)
