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%)