This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit eedd4f849f8ae9fef97bdc455cff8629aaa60c2a Merge: 4f30423d4 d26026af5 Author: Zoi Kaoudi <[email protected]> AuthorDate: Tue Jun 3 14:46:06 2025 +0200 Merge pull request #555 from strangelookingnerd/migrate_to_junit5 Migrate tests to JUnit5 pom.xml | 2 +- .../java/org/apache/wayang/api/JavaApiTest.java | 113 ++++++------ .../test/scala/org/apache/wayang/api/ApiTest.scala | 53 +++--- .../serialization/OperatorSerializationTests.scala | 2 +- .../serialization/OtherSerializationTests.scala | 59 +++--- .../api/serialization/SerializationTestBase.scala | 28 ++- .../apache/wayang/api/sql/SqlToWayangRelTest.java | 197 +++++++++------------ wayang-applications/pom.xml | 8 +- .../wayang/apps/tpch/data/LineItemTupleTest.java | 41 ++--- .../org/apache/wayang/apps/kmeans/KmeansTest.scala | 4 +- .../basic/function/ProjectionDescriptorTest.java | 25 ++- .../wayang/basic/mapping/ReduceByMappingTest.java | 19 +- .../org/apache/wayang/basic/model/op/OpTest.java | 6 +- .../operators/MaterializedGroupByOperatorTest.java | 6 +- .../wayang/basic/operators/TextFileSourceTest.java | 15 +- .../apache/wayang/basic/types/RecordTypeTest.java | 26 +-- wayang-commons/wayang-core/pom.xml | 6 + .../test/java/org/apache/wayang/core/SlotTest.java | 15 +- .../wayang/core/mapping/OperatorPatternTest.java | 18 +- .../core/mapping/PlanTransformationTest.java | 46 ++--- .../wayang/core/mapping/SubplanPatternTest.java | 27 +-- .../AggregatingCardinalityEstimatorTest.java | 10 +- .../DefaultCardinalityEstimatorTest.java | 14 +- .../LoopSubplanCardinalityPusherTest.java | 47 ++--- .../cardinality/SubplanCardinalityPusherTest.java | 25 +-- .../channels/ChannelConversionGraphTest.java | 62 ++++--- .../costs/NestableLoadProfileEstimatorTest.java | 49 ++--- .../enumeration/StageAssignmentTraversalTest.java | 27 +-- .../core/plan/wayangplan/LoopIsolatorTest.java | 84 ++++----- .../wayang/core/plan/wayangplan/OperatorTest.java | 17 +- .../core/plan/wayangplan/SlotMappingTest.java | 38 ++-- .../wayang/core/platform/PartialExecutionTest.java | 18 +- .../wayang/core/plugin/DynamicPluginTest.java | 52 +++--- .../org/apache/wayang/core/util/BitmaskTest.java | 85 ++++----- .../core/util/ConsumerIteratorAdapterTest.java | 17 +- .../wayang/core/util/CrossProductIterableTest.java | 35 ++-- .../wayang/core/util/LimitedInputStreamTest.java | 19 +- .../wayang/core/util/ReflectionUtilsTest.java | 25 +-- .../wayang/core/util/WayangCollectionsTest.java | 14 +- .../core/util/mathex/ExpressionBuilderTest.java | 14 +- .../wayang/core/util/mathex/ExpressionTest.java | 48 ++--- .../commons/util/profiledb/ProfileDBTest.java | 42 ++--- .../operators/FlinkCartesianOperatorTest.java | 13 +- .../flink/operators/FlinkCoGroupOperatorTest.java | 18 +- .../flink/operators/FlinkCollectionSourceTest.java | 11 +- .../flink/operators/FlinkCountOperatorTest.java | 18 +- .../flink/operators/FlinkDistinctOperatorTest.java | 14 +- .../flink/operators/FlinkFilterOperatorTest.java | 13 +- .../flink/operators/FlinkFlatMapOperatorTest.java | 13 +- .../FlinkGlobalMaterializedGroupOperatorTest.java | 15 +- .../operators/FlinkGlobalReduceOperatorTest.java | 23 +-- .../flink/operators/FlinkJoinOperatorTest.java | 20 +-- .../operators/FlinkMapPartitionsOperatorTest.java | 13 +- .../FlinkMaterializedGroupByOperatorTest.java | 17 +- .../flink/operators/FlinkOperatorTestBase.java | 6 +- .../flink/operators/FlinkReduceByOperatorTest.java | 17 +- .../flink/operators/FlinkSortOperatorTest.java | 13 +- .../flink/operators/FlinkUnionAllOperatorTest.java | 14 +- .../apache/wayang/flink/test/ChannelFactory.java | 6 +- .../operators/GiraphPagaRankOperatorTest.java | 17 +- .../wayang/java/execution/JavaExecutorTest.java | 11 +- .../java/operators/JavaCartesianOperatorTest.java | 13 +- .../java/operators/JavaCoGroupOperatorTest.java | 18 +- .../java/operators/JavaCollectionSourceTest.java | 11 +- .../java/operators/JavaCountOperatorTest.java | 13 +- .../java/operators/JavaDistinctOperatorTest.java | 13 +- .../operators/JavaExecutionOperatorTestBase.java | 6 +- .../java/operators/JavaFilterOperatorTest.java | 13 +- .../JavaGlobalMaterializedGroupOperatorTest.java | 20 ++- .../operators/JavaGlobalReduceOperatorTest.java | 17 +- .../java/operators/JavaJoinOperatorTest.java | 11 +- .../java/operators/JavaKafkaTopicSinkTest.java | 54 +++--- .../java/operators/JavaKafkaTopicSourceTest.java | 46 +++-- .../java/operators/JavaLocalCallbackSinkTest.java | 11 +- .../JavaMaterializedGroupByOperatorTest.java | 14 +- .../java/operators/JavaObjectFileSinkTest.java | 6 +- .../java/operators/JavaObjectFileSourceTest.java | 14 +- .../operators/JavaRandomSampleOperatorTest.java | 19 +- .../java/operators/JavaReduceByOperatorTest.java | 14 +- .../operators/JavaReservoirSampleOperatorTest.java | 15 +- .../java/operators/JavaSortOperatorTest.java | 13 +- .../java/operators/JavaTextFileSinkTest.java | 24 ++- .../java/operators/JavaTextFileSourceTest.java | 57 +++--- .../java/operators/JavaUnionAllOperatorTest.java | 13 +- .../apache/wayang/java/test/ChannelFactory.java | 6 +- .../apache/wayang/java/test/KafkaClientTest.java | 15 +- .../wayang/jdbc/execution/JdbcExecutorTest.java | 22 +-- .../jdbc/operators/JdbcJoinOperatorTest.java | 21 +-- .../wayang/jdbc/operators/JdbcTableSourceTest.java | 10 +- .../wayang/jdbc/operators/OperatorTestBase.java | 6 +- .../jdbc/operators/SqlToRddOperatorTest.java | 15 +- .../jdbc/operators/SqlToStreamOperatorTest.java | 15 +- .../SparkBernoulliSampleOperatorTest.java | 17 +- .../operators/SparkCartesianOperatorTest.java | 13 +- .../spark/operators/SparkCoGroupOperatorTest.java | 18 +- .../spark/operators/SparkCollectionSourceTest.java | 11 +- .../spark/operators/SparkCountOperatorTest.java | 13 +- ...parkDecisionTreeClassificationOperatorTest.java | 19 +- .../spark/operators/SparkDistinctOperatorTest.java | 13 +- .../spark/operators/SparkFilterOperatorTest.java | 13 +- .../spark/operators/SparkFlatMapOperatorTest.java | 13 +- .../SparkGlobalMaterializedGroupOperatorTest.java | 20 ++- .../operators/SparkGlobalReduceOperatorTest.java | 23 +-- .../spark/operators/SparkJoinOperatorTest.java | 21 +-- .../spark/operators/SparkKMeansOperatorTest.java | 20 ++- .../SparkLinearRegressionOperatorTest.java | 20 ++- .../operators/SparkMapPartitionsOperatorTest.java | 13 +- .../SparkMaterializedGroupByOperatorTest.java | 14 +- .../spark/operators/SparkObjectFileSinkTest.java | 6 +- .../spark/operators/SparkObjectFileSourceTest.java | 14 +- .../spark/operators/SparkOperatorTestBase.java | 8 +- .../SparkRandomPartitionSampleOperatorTest.java | 15 +- .../spark/operators/SparkReduceByOperatorTest.java | 14 +- .../SparkShufflePartitionSampleOperatorTest.java | 15 +- .../spark/operators/SparkSortOperatorTest.java | 13 +- .../spark/operators/SparkTextFileSinkTest.java | 6 +- .../spark/operators/SparkUnionAllOperatorTest.java | 13 +- .../apache/wayang/spark/test/ChannelFactory.java | 6 +- .../tensorflow/model/TensorflowModelTest.java | 8 +- .../operators/TensorflowOperatorTestBase.java | 8 +- .../operators/JavaExecutionOperatorTestBase.java | 6 +- .../iejoin/operators/JavaIEJoinOperatorTest.java | 11 +- .../iejoin/operators/SparkIEJoinOperatorTest.java | 11 +- .../iejoin/operators/SparkIEJoinOperatorTest2.java | 11 +- .../iejoin/operators/SparkIEJoinOperatorTest3.java | 11 +- .../iejoin/operators/SparkIEJoinOperatorTest4.java | 11 +- .../operators/SparkIESelfJoinOperatorTest.java | 13 +- .../iejoin/operators/SparkOperatorTestBase.java | 6 +- .../apache/wayang/iejoin/test/ChannelFactory.java | 6 +- .../apache/wayang/tests/FlinkIntegrationIT.java | 166 ++++++++--------- .../org/apache/wayang/tests/FullIntegrationIT.java | 138 +++++++-------- .../apache/wayang/tests/GiraphIntegrationIT.java | 22 ++- .../org/apache/wayang/tests/JavaIntegrationIT.java | 155 ++++++++-------- .../apache/wayang/tests/PostgresIntegrationIT.java | 19 +- .../java/org/apache/wayang/tests/RegressionIT.java | 11 +- .../apache/wayang/tests/SparkIntegrationIT.java | 142 +++++++-------- .../wayang/tests/TensorflowIntegrationIT.java | 5 +- .../org/apache/wayang/tests/TensorflowIrisIT.java | 11 +- .../wayang/tests/TensorflowIrisScalaLikeApiIT.java | 4 +- .../java/org/apache/wayang/tests/WayangPlans.java | 33 ++-- .../apache/wayang/tests/WayangPlansOperators.java | 74 ++++---- .../java/org/apache/wayang/tests/WordCountIT.java | 47 ++--- 142 files changed, 1785 insertions(+), 1790 deletions(-)
