You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by zi...@apache.org on 2022/06/24 06:34:41 UTC
[inlong] branch master updated (08cfc8f92 -> 247a3a84a)
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 08cfc8f92 [INLONG-4752][Dashboard] Keyword param error(#4753)
add 247a3a84a [INLONG-4685][Sort] Optimize the metadata implementation of Extract Nodes and Load Nodes (#4754)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/sort/protocol/Metadata.java | 146 ++++++++++
.../protocol/node/extract/KafkaExtractNode.java | 62 ++++-
.../protocol/node/extract/MongoExtractNode.java | 28 +-
.../protocol/node/extract/MySqlExtractNode.java | 76 +++++-
.../protocol/node/extract/OracleExtractNode.java | 45 ++--
.../protocol/node/extract/PostgresExtractNode.java | 22 +-
.../node/extract/SqlServerExtractNode.java | 33 ++-
.../sort/protocol/node/load/KafkaLoadNode.java | 65 ++++-
.../node/extract/KafkaExtractNodeTest.java | 36 ++-
.../node/extract/MongoExtractNodeTest.java | 36 ++-
.../node/extract/MySqlExtractNodeTest.java | 40 ++-
.../node/extract/OracleExtractNodeTest.java | 29 +-
.../node/extract/PostgresExtractNodeTest.java | 24 ++
.../node/extract/SqlServerExtractNodeTest.java | 24 ++
.../sort/protocol/node/load/KafkaLoadNodeTest.java | 32 +++
.../inlong/sort/parser/impl/FlinkSqlParser.java | 16 +-
.../apache/inlong/sort/util/MetaInfoParseUtil.java | 294 ---------------------
.../sort/parser/MongoExtractFlinkSqlParseTest.java | 46 +++-
.../sort/parser/OracleExtractSqlParseTest.java | 46 +++-
.../parser/PostgresExtractFlinkSqlParseTest.java | 45 +++-
.../sort/parser/SqlServerNodeSqlParseTest.java | 50 +++-
.../inlong/sort/util/MetaInfoParseUtilTest.java | 189 -------------
22 files changed, 796 insertions(+), 588 deletions(-)
create mode 100644 inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/Metadata.java
delete mode 100644 inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/util/MetaInfoParseUtil.java
delete mode 100644 inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/util/MetaInfoParseUtilTest.java