[inlong] branch master updated (281c6e7c5 -> 31ff2112a)

[zi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from 281c6e7c5 [INLONG-5577][Sort][Manager] Support function fieldType (#5579)
     add 31ff2112a [INLONG-5576][Sort] Add Redis extract node and support temporal join (#5588)

No new revisions were added by this update.

Summary of changes:
 .../FieldRelation.java => LookupOptions.java}      |  56 ++-
 .../sort/protocol/constant/RedisConstant.java      | 105 +++++
 .../inlong/sort/protocol/enums/ExtractMode.java    |  20 +-
 ...ulsarScanStartupMode.java => RedisCommand.java} |  49 ++-
 .../{PulsarScanStartupMode.java => RedisMode.java} |  46 ++-
 .../inlong/sort/protocol/node/ExtractNode.java     |  12 +-
 .../org/apache/inlong/sort/protocol/node/Node.java |   4 +-
 .../protocol/node/extract/RedisExtractNode.java    | 434 +++++++++++++++++++++
 ...oinNodeRelation.java => InnerTemporalJoin.java} |  22 +-
 .../transformation/relation/JoinRelation.java      |   8 +-
 ...odeRelation.java => LeftOuterTemporalJoin.java} |  20 +-
 .../transformation/relation/NodeRelation.java      |   4 +-
 ...uterJoinNodeRelation.java => TemporalJoin.java} |  26 +-
 ...ractNodeTest.java => RedisExtractNodeTest.java} |  26 +-
 .../sort/redis/common/config/RedisOptions.java     |   8 +-
 .../sort/redis/table/RedisDynamicTableFactory.java |   2 +-
 inlong-sort/sort-core/pom.xml                      |   6 +
 .../inlong/sort/parser/impl/FlinkSqlParser.java    |  59 ++-
 .../sort/parser/RedisTemporalJoinSqlParseTest.java | 221 +++++++++++
 19 files changed, 987 insertions(+), 141 deletions(-)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/{transformation/FieldRelation.java => LookupOptions.java} (50%)
 create mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/RedisConstant.java
 copy inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/dto/Jars.java => inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/ExtractMode.java (77%)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/{PulsarScanStartupMode.java => RedisCommand.java} (62%)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/enums/{PulsarScanStartupMode.java => RedisMode.java} (66%)
 create mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/RedisExtractNode.java
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/relation/{LeftOuterJoinNodeRelation.java => InnerTemporalJoin.java} (79%)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/relation/{LeftOuterJoinNodeRelation.java => LeftOuterTemporalJoin.java} (80%)
 copy inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/relation/{LeftOuterJoinNodeRelation.java => TemporalJoin.java} (76%)
 copy inlong-sort/sort-common/src/test/java/org/apache/inlong/sort/protocol/node/extract/{TubeMQExtractNodeTest.java => RedisExtractNodeTest.java} (61%)
 create mode 100644 inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/RedisTemporalJoinSqlParseTest.java