This is an automated email from the ASF dual-hosted git repository.
xushiyan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from dcedf139d32 Fix some comments on schema change (#8084)
add 168005f020d [HUDI-5872] Abstraction for DeltaSyncService and
DeltaStreamerMetrics (#8086)
No new revisions were added by this update.
Summary of changes:
.../testsuite/HoodieDeltaStreamerWrapper.java | 8 +-
.../integ/testsuite/dag/nodes/HiveQueryNode.java | 6 +-
.../org/apache/hudi/utilities/UtilHelpers.java | 17 +-
.../hudi/utilities/deltastreamer/DeltaSync.java | 11 +-
.../deltastreamer/HoodieDeltaStreamer.java | 127 +++++++-------
.../deltastreamer/HoodieDeltaStreamerMetrics.java | 98 ++++++-----
.../HoodieIngestionException.java} | 19 ++-
.../ingestion/HoodieIngestionMetrics.java | 57 +++++++
.../ingestion/HoodieIngestionService.java | 185 +++++++++++++++++++++
.../hudi/utilities/sources/AvroKafkaSource.java | 6 +-
.../hudi/utilities/sources/JsonKafkaSource.java | 4 +-
.../apache/hudi/utilities/sources/KafkaSource.java | 11 +-
.../hudi/utilities/sources/ProtoKafkaSource.java | 4 +-
.../utilities/sources/debezium/DebeziumSource.java | 25 ++-
.../sources/debezium/MysqlDebeziumSource.java | 4 +-
.../sources/debezium/PostgresDebeziumSource.java | 4 +-
.../utilities/sources/helpers/KafkaOffsetGen.java | 7 +-
.../deltastreamer/TestHoodieDeltaStreamer.java | 4 +-
.../utilities/sources/BaseTestKafkaSource.java | 4 +-
.../utilities/sources/TestAvroKafkaSource.java | 6 +-
.../sources/TestJsonKafkaSourcePostProcessor.java | 6 +-
.../debezium/TestAbstractDebeziumSource.java | 4 +-
.../sources/helpers/TestKafkaOffsetGen.java | 4 +-
23 files changed, 443 insertions(+), 178 deletions(-)
copy
hudi-utilities/src/main/java/org/apache/hudi/utilities/{exception/HoodieSourcePostProcessException.java
=> ingestion/HoodieIngestionException.java} (67%)
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionMetrics.java
create mode 100644
hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionService.java
