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/08/08 04:37:13 UTC

[inlong] branch master updated (6ee93e746 -> f8464ea04)

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 6ee93e746 [INLONG-5315][Sort] Import all changelog mode data ingest into JDBC (#5316)
     add f8464ea04 [INLONG-5100][Sort] Add reporting metrics for JDBC (#5200)

No new revisions were added by this update.

Summary of changes:
 .../sort/protocol/node/load/PostgresLoadNode.java  |   3 +-
 ...QLPostgresDialect.java => PostgresDialect.java} |  53 +--
 .../jdbc/internal/GenericJdbcSinkFunction.java     |  75 ++++
 .../jdbc/internal/JdbcBatchingOutputFormat.java    | 464 +++++++++++++++++++++
 .../jdbc/internal/TableJdbcUpsertOutputFormat.java | 218 ++++++++++
 .../inlong/sort/jdbc/metric/MetricData.java}       | 105 +----
 .../jdbc/table/JdbcDynamicOutputFormatBuilder.java | 179 ++++----
 .../sort/jdbc/table/JdbcDynamicTableFactory.java   |  12 +-
 .../sort/jdbc/table/JdbcDynamicTableSink.java      | 267 ++++++------
 9 files changed, 1032 insertions(+), 344 deletions(-)
 copy inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/dialect/{TDSQLPostgresDialect.java => PostgresDialect.java} (71%)
 create mode 100644 inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/GenericJdbcSinkFunction.java
 create mode 100644 inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java
 create mode 100644 inlong-sort/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/TableJdbcUpsertOutputFormat.java
 copy inlong-sort/sort-connectors/{connector-base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java => jdbc/src/main/java/org/apache/inlong/sort/jdbc/metric/MetricData.java} (51%)