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 e6ec72c684 [INLONG-10512][Manager] Support preview of data in kv data
type (#10513)
add d6be026cb9 [INLONG-8464][Sort] Add JDBC connector on Flink 1.15
(#10491)
No new revisions were added by this update.
Summary of changes:
.../sort-connectors/jdbc/pom.xml | 43 ++---
.../clickhouse/ClickHouseRowConverter.java | 3 +-
.../sort/jdbc/dialect/JdbcDialectFactory.java | 51 ++++++
.../sort/jdbc/dialect/JdbcDialectLoader.java | 110 +++++++++++++
.../dialect/clickhouse}/ClickHouseDialect.java | 90 +++++-----
.../clickhouse/ClickHouseDialectFactory.java} | 19 +--
.../jdbc/internal/GenericJdbcSinkFunction.java | 4 +-
.../sort/jdbc/internal/JdbcOutputFormat.java | 182 ++-------------------
.../jdbc/internal/TableJdbcUpsertOutputFormat.java | 13 +-
.../sort/jdbc/table/JdbcDynamicTableFactory.java | 124 +++++---------
.../sort/jdbc/table/JdbcDynamicTableSink.java | 11 +-
.../sort/jdbc/table/JdbcOutputFormatBuilder.java | 9 +-
.../org.apache.flink.table.factories.Factory | 0
...he.inlong.sort.jdbc.dialect.JdbcDialectFactory} | 2 +-
.../sort-flink-v1.15/sort-connectors/pom.xml | 1 +
licenses/inlong-sort-connectors/LICENSE | 26 ++-
16 files changed, 317 insertions(+), 371 deletions(-)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/jdbc/pom.xml (78%)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/converter/clickhouse/ClickHouseRowConverter.java
(94%)
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/JdbcDialectFactory.java
create mode 100644
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/JdbcDialectLoader.java
copy
inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect
=>
sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/clickhouse}/ClickHouseDialect.java
(80%)
copy
inlong-sort/{sort-common/src/test/java/org/apache/inlong/sort/protocol/transformation/operator/EmptyOperatorTest.java
=>
sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/clickhouse/ClickHouseDialectFactory.java}
(66%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/GenericJdbcSinkFunction.java
(98%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcOutputFormat.java
(65%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/TableJdbcUpsertOutputFormat.java
(97%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableFactory.java
(69%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableSink.java
(95%)
copy inlong-sort/sort-flink/{sort-flink-v1.18 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcOutputFormatBuilder.java
(97%)
copy inlong-sort/sort-flink/{sort-flink-v1.13 =>
sort-flink-v1.15}/sort-connectors/jdbc/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
(100%)
copy
inlong-sort/sort-flink/{sort-flink-v1.13/sort-connectors/iceberg/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory
=>
sort-flink-v1.15/sort-connectors/jdbc/src/main/resources/META-INF/services/org.apache.inlong.sort.jdbc.dialect.JdbcDialectFactory}
(91%)
