This is an automated email from the ASF dual-hosted git repository.
yihua pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from e9caf7eb4d9e chore(deps): bump org.glassfish:jakarta.el from 3.0.3 to
3.0.4 in hudi-cli-bundle (#17651)
add 84e76880d3de refactor: Add Lombok annotations to hudi-integ-test
module (#17667)
No new revisions were added by this update.
Summary of changes:
hudi-integ-test/pom.xml | 6 +++
.../testsuite/HoodieContinuousTestSuiteWriter.java | 6 +--
.../testsuite/HoodieInlineTestSuiteWriter.java | 8 ++-
.../testsuite/HoodieMultiWriterTestSuiteJob.java | 20 ++++----
.../hudi/integ/testsuite/HoodieTestSuiteJob.java | 12 ++---
.../integ/testsuite/HoodieTestSuiteWriter.java | 14 ++++--
.../SparkDataSourceContinuousIngestTool.java | 8 ++-
.../testsuite/configuration/DFSDeltaConfig.java | 50 ++++---------------
.../integ/testsuite/configuration/DeltaConfig.java | 26 +++-------
.../hudi/integ/testsuite/dag/ExecutionContext.java | 20 +++++---
.../hudi/integ/testsuite/dag/WorkflowDag.java | 29 ++---------
.../hudi/integ/testsuite/dag/WriterContext.java | 17 ++++---
.../integ/testsuite/dag/nodes/BaseQueryNode.java | 3 ++
.../dag/nodes/BaseValidateDatasetNode.java | 20 ++++----
.../integ/testsuite/dag/nodes/BulkInsertNode.java | 3 ++
.../hudi/integ/testsuite/dag/nodes/CleanNode.java | 3 ++
.../integ/testsuite/dag/nodes/ClusteringNode.java | 5 +-
.../integ/testsuite/dag/nodes/CompactNode.java | 2 +
.../hudi/integ/testsuite/dag/nodes/DagNode.java | 40 +++++----------
.../hudi/integ/testsuite/dag/nodes/DelayNode.java | 15 +++---
.../dag/nodes/DeleteInputDatasetNode.java | 2 +
.../hudi/integ/testsuite/dag/nodes/DeleteNode.java | 2 +
.../integ/testsuite/dag/nodes/HiveQueryNode.java | 3 ++
.../integ/testsuite/dag/nodes/HiveSyncNode.java | 2 +
.../hudi/integ/testsuite/dag/nodes/InsertNode.java | 3 ++
.../testsuite/dag/nodes/InsertOverwriteNode.java | 3 ++
.../dag/nodes/InsertOverwriteTableNode.java | 3 ++
.../integ/testsuite/dag/nodes/PrestoQueryNode.java | 3 ++
.../integ/testsuite/dag/nodes/RollbackNode.java | 5 +-
.../testsuite/dag/nodes/ScheduleCompactNode.java | 3 ++
.../testsuite/dag/nodes/SparkSQLQueryNode.java | 5 +-
.../integ/testsuite/dag/nodes/TrinoQueryNode.java | 3 ++
.../hudi/integ/testsuite/dag/nodes/UpsertNode.java | 3 ++
.../dag/nodes/ValidateAsyncOperations.java | 12 ++---
.../testsuite/dag/nodes/ValidateDatasetNode.java | 7 ++-
.../integ/testsuite/dag/nodes/ValidateNode.java | 5 +-
.../testsuite/dag/scheduler/DagScheduler.java | 11 ++---
.../dag/scheduler/SaferSchemaDagScheduler.java | 11 ++---
.../integ/testsuite/generator/DeltaGenerator.java | 22 ++++-----
.../GenericRecordFullPayloadGenerator.java | 14 ++----
.../generator/UpdateGeneratorIterator.java | 4 --
.../helpers/DFSTestSuitePathSelector.java | 10 ++--
.../reader/DFSHoodieDatasetInputReader.java | 6 +--
.../schema/TestSuiteFileBasedSchemaProvider.java | 5 --
.../streaming/StructuredStreamingSinkUtil.java | 12 ++---
.../testsuite/writer/AvroFileDeltaInputWriter.java | 12 ++---
.../integ/testsuite/writer/DeltaWriteStats.java | 41 +++-------------
.../integ/testsuite/writer/DeltaWriterFactory.java | 6 +--
.../org/apache/hudi/integ/HoodieTestHiveBase.java | 5 +-
.../java/org/apache/hudi/integ/ITTestBase.java | 57 +++++++++-------------
50 files changed, 251 insertions(+), 336 deletions(-)
