This is an automated email from the ASF dual-hosted git repository.
zkaoudi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
from 4f30423d4 Merge pull request #580 from xristlamp/main
add 48df1d0fa Migrate tests to JUnit5
add 651440b67 Fix Scala tests
add a4dab0e68 Merge branch 'main' into migrate_to_junit5
add 8a8ee7fdb Merge branch 'main' into migrate_to_junit5
add 9498b4a32 Fix integration tests
add bb3cb2bba Merge branch 'main' into migrate_to_junit5
add d26026af5 Fix integration tests
new eedd4f849 Merge pull request #555 from
strangelookingnerd/migrate_to_junit5
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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(-)
