This is an automated email from the ASF dual-hosted git repository.
yunqing pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git
from 0671c3a45 [INLONG-6678][Dashboard] Add sinkType parameter in
sinkFieldList (#6679)
add 40e888598 [INLONG-6584][Sort] Add read phase metric and table level
metric for MySQL (#6670)
No new revisions were added by this update.
Summary of changes:
.../org/apache/inlong/sort/base/Constants.java | 32 +++
.../apache/inlong/sort/base/enums/ReadPhase.java | 80 +++++++
.../inlong/sort/base/metric/MetricOption.java | 21 +-
.../inlong/sort/base/metric/MetricState.java | 11 +
.../inlong/sort/base/metric/SourceMetricData.java | 4 +-
.../base/metric/phase/ReadPhaseMetricData.java | 106 +++++++++
.../sort/base/metric/sub/SourceSubMetricData.java} | 51 ++---
.../base/metric/sub/SourceTableMetricData.java | 240 +++++++++++++++++++++
.../inlong/sort/base/util/MetricStateUtils.java | 73 +++++++
.../sort/cdc/debezium/DebeziumSourceFunction.java | 31 ++-
.../apache/inlong/sort/cdc/mysql/MySqlSource.java | 9 +-
.../sort/cdc/mysql/table/MySqlTableSource.java | 1 +
12 files changed, 621 insertions(+), 38 deletions(-)
create mode 100644
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/enums/ReadPhase.java
create mode 100644
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/phase/ReadPhaseMetricData.java
copy
inlong-sort/{sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/common/VarBinaryTypeInfo.java
=>
sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/sub/SourceSubMetricData.java}
(56%)
create mode 100644
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/sub/SourceTableMetricData.java
