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%)
