You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/08/08 08:21:19 UTC
[inlong] branch master updated (e7b0170f5 -> 0d0f2e2f0)
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%)