This is an automated email from the ASF dual-hosted git repository.
healchow pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
from d2b380a9b [INLONG-4303][Sort] Iceberg Load Node add required option
(#4304)
add 77affe87b [INLONG-4312][Sort] Add SqlServer load node (#4316)
No new revisions were added by this update.
Summary of changes:
inlong-sort/pom.xml | 33 ++++
.../apache/inlong/sort/protocol/node/LoadNode.java | 4 +-
.../org/apache/inlong/sort/protocol/node/Node.java | 4 +-
...ostgresLoadNode.java => SqlServerLoadNode.java} | 78 ++++----
inlong-sort/sort-connectors/hive/pom.xml | 4 +-
.../inlong/sort/jdbc/dialect/SqlServerDialect.java | 196 +++++++++++++++++++++
.../sort/jdbc/sqlserver/SqlServerRowConvert.java | 30 ++--
.../inlong/sort/jdbc/table/JdbcDialects.java | 4 +-
inlong-sort/sort-connectors/mysql-cdc/pom.xml | 3 +-
inlong-sort/sort-connectors/pom.xml | 12 +-
...ateTest.java => SqlServerNodeSqlParseTest.java} | 92 +++++-----
licenses/inlong-sort/LICENSE | 4 +
12 files changed, 343 insertions(+), 121 deletions(-)
copy
inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/{PostgresLoadNode.java
=> SqlServerLoadNode.java} (52%)
create mode 100644
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/SqlServerDialect.java
copy
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/counter/CounterLong.java
=>
inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/sqlserver/SqlServerRowConvert.java
(62%)
copy
inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/{AllMigrateTest.java
=> SqlServerNodeSqlParseTest.java} (53%)
