[inlong] branch master updated (dfd57b119 -> 4fa1218a4)

[do...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


    from dfd57b119 [INLONG-5722][Agent] Support Redis Source (#5780)
     add 4fa1218a4 [INLONG-5903][Sort] Make InLong metric constructs factory more cohesive (#5906)

No new revisions were added by this update.

Summary of changes:
 .../inlong/sort/configuration/Constants.java       |  22 +++-
 .../apache/inlong/sort/protocol/InlongMetric.java  |  22 +---
 .../org/apache/inlong/sort/base/Constants.java     |  11 +-
 .../apache/inlong/sort/base/metric/MetricData.java |  35 ++++-
 .../inlong/sort/base/metric/MetricOption.java      | 141 ++++++++++++++++-----
 .../inlong/sort/base/metric/SinkMetricData.java    | 128 +++++++++++--------
 .../inlong/sort/base/metric/SourceMetricData.java  | 105 +++++++--------
 .../sort/base/util/ValidateMetricOptionUtils.java  |  39 ------
 .../sort/elasticsearch/ElasticsearchSinkBase.java  |  26 ++--
 .../table/RowElasticsearchSinkFunction.java        |  55 ++------
 .../sort/filesystem/FileSystemTableSink.java       |   2 -
 .../filesystem/stream/AbstractStreamingWriter.java |  25 ++--
 .../sort/hbase/HBase2DynamicTableFactory.java      |   2 -
 .../inlong/sort/hbase/sink/HBaseSinkFunction.java  |  46 +++----
 .../hive/filesystem/AbstractStreamingWriter.java   |  25 ++--
 .../iceberg/flink/FlinkDynamicTableFactory.java    |  11 +-
 .../sort/iceberg/flink/IcebergTableSink.java       |   2 +-
 .../inlong/sort/iceberg/flink/sink/FlinkSink.java  |   2 +-
 .../iceberg/flink/sink/IcebergStreamWriter.java    |   7 -
 .../inlong/sort/iceberg/IcebergTableSink.java      |   2 +-
 .../apache/inlong/sort/iceberg/sink/FlinkSink.java |   2 +-
 .../sort/iceberg/sink/IcebergStreamWriter.java     |  25 ++--
 .../jdbc/internal/JdbcBatchingOutputFormat.java    |  76 +++--------
 .../inlong/sort/kafka/FlinkKafkaConsumerBase.java  |  52 +++-----
 .../inlong/sort/kafka/FlinkKafkaProducer.java      |  48 ++-----
 .../table/DynamicKafkaDeserializationSchema.java   |   8 +-
 .../sort/cdc/mongodb/DebeziumSourceFunction.java   |  32 ++---
 .../mongodb/table/MongoDBTableSourceFactory.java   |   2 -
 .../sort/cdc/debezium/DebeziumSourceFunction.java  |  34 ++---
 .../inlong/sort/cdc/mysql/source/MySqlSource.java  |  36 ++----
 .../source/metrics/MySqlSourceReaderMetrics.java   | 124 ++----------------
 .../mysql/table/MySqlTableInlongSourceFactory.java |   2 -
 .../sort/cdc/oracle/DebeziumSourceFunction.java    |  32 ++---
 .../cdc/oracle/table/OracleTableSourceFactory.java |   2 -
 .../DebeziumSourceFunction.java                    |  43 ++-----
 .../cdc/postgres/table/PostgreSQLTableFactory.java |   2 -
 .../apache/inlong/sort/pulsar/table/Constants.java |  32 -----
 .../table/DynamicPulsarDeserializationSchema.java  |  41 ++----
 .../pulsar/table/PulsarDynamicTableFactory.java    |   2 +-
 .../table/UpsertPulsarDynamicTableFactory.java     |   2 +-
 .../sqlserver/table/DebeziumSourceFunction.java    |  56 ++------
 .../inlong/sort/parser/impl/FlinkSqlParser.java    |  25 ++--
 42 files changed, 515 insertions(+), 871 deletions(-)
 delete mode 100644 inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/util/ValidateMetricOptionUtils.java
 delete mode 100644 inlong-sort/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/Constants.java