[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344619136 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/job/HoodieDeltaStreamerWrapper.java ## @@ -0,0 +1,69

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344613844 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/writer/DeltaWriter.java ## @@ -0,0 +1,184 @@ +/* + *

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344612399 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/writer/AvroDeltaInputWriter.java ## @@ -0,0 +1,119 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344614898 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/writer/SparkAvroDeltaInputWriter.java ## @@ -0,0 +1,65

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344618550 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/reader/DFSParquetDeltaInputReader.java ## @@ -0,0

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344612991 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/writer/AvroDeltaInputWriter.java ## @@ -0,0 +1,119 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344618562 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/reader/DFSParquetDeltaInputReader.java ## @@ -0,0

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344621141 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/nodes/HiveQueryNode.java ## @@ -0,0 +1,99 @@ +/* +

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344619724 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/job/HoodieTestSuiteJob.java ## @@ -0,0 +1,183 @@ +/* +

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r344568411 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/nodes/DagNode.java ## @@ -0,0 +1,125 @@ +/* + *

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r343002991 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/DagUtils.java ## @@ -0,0 +1,247 @@ +/* + * Licensed

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342983113 ## File path: hudi-utilities/src/main/java/org/apache/hudi/utilities/converter/Converter.java ## @@ -0,0 +1,33 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342982493 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/DeltaSinkType.java ## @@ -0,0 +1,26 @@ +/* + * Licensed

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342516577 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/helpers/HiveServerWrapper.java ## @@ -0,0 +1,67 @@ +/*

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342404473 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/reader/DFSParquetDeltaInputReader.java ## @@ -0,0

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342443764 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/WorkflowDagGenerator.java ## @@ -0,0 +1,70 @@ +/*

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342404062 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/reader/SparkBasedReader.java ## @@ -0,0 +1,68 @@ +/* +

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342517208 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/helpers/DFSTestSuitePathSelector.java ## @@ -0,0 +1,92

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342396995 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/configuration/DeltaConfig.java ## @@ -0,0 +1,273 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342396876 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/helpers/HiveServerWrapper.java ## @@ -0,0 +1,67 @@ +/*

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r342396714 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/nodes/DagNode.java ## @@ -0,0 +1,125 @@ +/* + *

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r341948583 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/writer/AvroDeltaInputWriter.java ## @@ -0,0 +1,119 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r341909308 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/DFSDeltaWriterAdapter.java ## @@ -0,0 +1,66 @@ +/* + *

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r341897178 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/scheduler/DagScheduler.java ## @@ -0,0 +1,113 @@

[GitHub] [incubator-hudi] yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor)

yanghua commented on a change in pull request #991: Hudi Test Suite (Refactor) URL: https://github.com/apache/incubator-hudi/pull/991#discussion_r341896396 ## File path: hudi-bench/src/main/java/org/apache/hudi/bench/dag/nodes/DagNode.java ## @@ -0,0 +1,104 @@ +package