Path	Lines of Code
python/src/pywy/tests/__init__.py	1
python/src/pywy/tests/filter_test.py	20
python/src/pywy/tests/join_test.py	20
python/src/pywy/tests/json_test.py	10
python/src/pywy/tests/test.py	50
python/src/pywy/tests/word_count.py	43
wayang-api/wayang-api-scala-java/src/test/java/org/apache/wayang/api/JavaApiTest.java	538
wayang-api/wayang-api-scala-java/src/test/scala/org/apache/wayang/api/ApiTest.scala	399
wayang-api/wayang-api-scala-java/src/test/scala/org/apache/wayang/api/serialization/OperatorSerializationTests.scala	359
wayang-api/wayang-api-scala-java/src/test/scala/org/apache/wayang/api/serialization/OtherSerializationTests.scala	271
wayang-api/wayang-api-scala-java/src/test/scala/org/apache/wayang/api/serialization/SerializationTestBase.scala	84
wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlAPI.java	115
wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java	46
wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlToWayangRelTest.java	512
wayang-benchmark/src/test/java/org/apache/wayang/apps/tpch/data/LineItemTupleTest.java	42
wayang-benchmark/src/test/resources/kmeans-datagenerator.py	26
wayang-benchmark/src/test/scala/org/apache/wayang/apps/kmeans/KmeansTest.scala	46
wayang-benchmark/src/test/scala/org/apache/wayang/apps/util/ParametersTest.scala	49
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/function/ProjectionDescriptorTest.java	46
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/mapping/ReduceByMappingTest.java	60
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/model/op/OpTest.java	39
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/operators/MaterializedGroupByOperatorTest.java	23
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/operators/TextFileSourceTest.java	63
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/operators/test/TestSink.java	8
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/operators/test/TestSource.java	8
wayang-commons/wayang-basic/src/test/java/org/apache/wayang/basic/types/RecordTypeTest.java	21
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/SlotTest.java	22
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/mapping/OperatorPatternTest.java	17
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/mapping/PlanTransformationTest.java	77
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/mapping/SubplanPatternTest.java	59
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/mapping/test/TestSinkMapping.java	41
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/mapping/test/TestSinkToTestSink2Factory.java	15
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/cardinality/AggregatingCardinalityEstimatorTest.java	24
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimatorTest.java	29
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/cardinality/LoopSubplanCardinalityPusherTest.java	166
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusherTest.java	106
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraphTest.java	238
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimatorTest.java	167
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversalTest.java	94
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/executionplan/test/TestChannel.java	21
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/LoopIsolatorTest.java	110
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/OperatorTest.java	52
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/SlotMappingTest.java	66
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestCustomMapOperator.java	9
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestFilterOperator.java	33
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestJoin.java	37
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestLoopHead.java	66
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestMapOperator.java	30
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSink.java	20
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSink2.java	8
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plan/wayangplan/test/TestSource.java	24
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/platform/PartialExecutionTest.java	52
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/plugin/DynamicPluginTest.java	93
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/DummyExecutionOperator.java	45
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/DummyExternalReusableChannel.java	31
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/DummyNonReusableChannel.java	31
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/DummyPlatform.java	44
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/DummyReusableChannel.java	31
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/MockFactory.java	59
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/SerializableDummyExecutionOperator.java	18
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/TestDataUnit.java	3
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/test/TestDataUnit2.java	3
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/BitmaskTest.java	102
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/ConsumerIteratorAdapterTest.java	32
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/CrossProductIterableTest.java	120
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/LimitedInputStreamTest.java	24
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/ReflectionUtilsTest.java	60
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/WayangCollectionsTest.java	25
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/mathex/ExpressionBuilderTest.java	43
wayang-commons/wayang-core/src/test/java/org/apache/wayang/core/util/mathex/ExpressionTest.java	75
wayang-commons/wayang-core/src/test/resources/empty-plugin.yaml	1
wayang-commons/wayang-core/src/test/resources/partial-plugin.yaml	6
wayang-commons/wayang-core/src/test/resources/test-plugin.yaml	16
wayang-commons/wayang-utils-profile-db/src/test/java/org/apache/wayang/commons/util/profiledb/ProfileDBTest.java	120
wayang-commons/wayang-utils-profile-db/src/test/java/org/apache/wayang/commons/util/profiledb/measurement/TestMemoryMeasurement.java	46
wayang-commons/wayang-utils-profile-db/src/test/java/org/apache/wayang/commons/util/profiledb/measurement/TestTimeMeasurement.java	41
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkCartesianOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkCoGroupOperatorTest.java	83
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkCollectionSourceTest.java	24
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkCountOperatorTest.java	28
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkDistinctOperatorTest.java	26
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkFilterOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkFlatMapOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperatorTest.java	56
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java	44
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperatorTest.java	36
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperatorTest.java	61
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java	60
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkReduceByOperatorTest.java	62
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkSortOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/operators/FlinkUnionAllOperatorTest.java	27
wayang-platforms/wayang-flink/src/test/java/org/apache/wayang/flink/test/ChannelFactory.java	43
wayang-platforms/wayang-generic-jdbc/src/test/java/org/apache/wayang/genericjdbc/SqlTest.java	60
wayang-platforms/wayang-generic-jdbc/src/test/java/org/apache/wayang/genericjdbc/SqlTest2.java	59
wayang-platforms/wayang-giraph/src/test/java/org/apache/wayang/giraph/operators/GiraphPagaRankOperatorTest.java	56
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/execution/JavaExecutorTest.java	91
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaCartesianOperatorTest.java	31
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaCoGroupOperatorTest.java	90
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaCollectionSourceTest.java	23
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaCountOperatorTest.java	25
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaDistinctOperatorTest.java	25
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaExecutionOperatorTestBase.java	64
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaFilterOperatorTest.java	27
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaGlobalMaterializedGroupOperatorTest.java	41
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaGlobalReduceOperatorTest.java	49
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaJoinOperatorTest.java	66
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaKafkaTopicSinkTest.java	86
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaKafkaTopicSourceTest.java	73
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaLocalCallbackSinkTest.java	20
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaMaterializedGroupByOperatorTest.java	43
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaObjectFileSinkTest.java	39
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaObjectFileSourceTest.java	45
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaRandomSampleOperatorTest.java	60
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaReduceByOperatorTest.java	50
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaReservoirSampleOperatorTest.java	43
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaSortOperatorTest.java	28
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaTextFileSinkTest.java	71
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaTextFileSourceTest.java	96
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/operators/JavaUnionAllOperatorTest.java	28
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/test/ChannelFactory.java	37
wayang-platforms/wayang-java/src/test/java/org/apache/wayang/java/test/KafkaClientTest.java	95
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/execution/JdbcExecutorTest.java	185
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/JdbcJoinOperatorTest.java	95
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/JdbcTableSourceTest.java	45
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/OperatorTestBase.java	54
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/SqlToRddOperatorTest.java	123
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/SqlToStreamOperatorTest.java	124
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/HsqldbFilterOperator.java	22
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/HsqldbJoinOperator.java	19
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/HsqldbPlatform.java	15
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/HsqldbProjectionOperator.java	22
wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/test/HsqldbTableSource.java	23
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperatorTest.java	42
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkCartesianOperatorTest.java	27
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkCoGroupOperatorTest.java	88
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkCollectionSourceTest.java	24
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkCountOperatorTest.java	24
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkDecisionTreeClassificationOperatorTest.java	61
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkDistinctOperatorTest.java	24
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkFilterOperatorTest.java	27
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkFlatMapOperatorTest.java	27
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperatorTest.java	42
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperatorTest.java	56
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkJoinOperatorTest.java	44
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkKMeansOperatorTest.java	57
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkLinearRegressionOperatorTest.java	57
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperatorTest.java	33
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperatorTest.java	54
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkObjectFileSinkTest.java	45
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkObjectFileSourceTest.java	45
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkOperatorTestBase.java	59
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperatorTest.java	46
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkReduceByOperatorTest.java	56
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperatorTest.java	49
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkSortOperatorTest.java	27
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkTextFileSinkTest.java	28
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/operators/SparkUnionAllOperatorTest.java	26
wayang-platforms/wayang-spark/src/test/java/org/apache/wayang/spark/test/ChannelFactory.java	43
wayang-platforms/wayang-tensorflow/src/test/java/org/apache/wayang/tensorflow/model/TensorflowModelTest.java	62
wayang-platforms/wayang-tensorflow/src/test/java/org/apache/wayang/tensorflow/operators/TensorflowOperatorTestBase.java	63
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/JavaExecutionOperatorTestBase.java	55
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperatorTest.java	55
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest.java	52
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest2.java	54
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest3.java	54
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest4.java	54
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperatorTest.java	42
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/operators/SparkOperatorTestBase.java	61
wayang-plugins/wayang-iejoin/src/test/java/org/apache/wayang/iejoin/test/ChannelFactory.java	58
wayang-tests-integration/pom.xml	259
wayang-tests-integration/src/test/java/org/apache/wayang/tests/FlinkIntegrationIT.java	337
wayang-tests-integration/src/test/java/org/apache/wayang/tests/FullIntegrationIT.java	385
wayang-tests-integration/src/test/java/org/apache/wayang/tests/GiraphIntegrationIT.java	39
wayang-tests-integration/src/test/java/org/apache/wayang/tests/JavaIntegrationIT.java	356
wayang-tests-integration/src/test/java/org/apache/wayang/tests/PostgresIntegrationIT.java	43
wayang-tests-integration/src/test/java/org/apache/wayang/tests/RegressionIT.java	37
wayang-tests-integration/src/test/java/org/apache/wayang/tests/SparkIntegrationIT.java	332
wayang-tests-integration/src/test/java/org/apache/wayang/tests/TensorflowIntegrationIT.java	96
wayang-tests-integration/src/test/java/org/apache/wayang/tests/TensorflowIrisIT.java	136
wayang-tests-integration/src/test/java/org/apache/wayang/tests/TensorflowIrisScalaLikeApiIT.java	110
wayang-tests-integration/src/test/java/org/apache/wayang/tests/WayangPlans.java	695
wayang-tests-integration/src/test/java/org/apache/wayang/tests/WayangPlansOperators.java	274
wayang-tests-integration/src/test/java/org/apache/wayang/tests/WordCountIT.java	316
wayang-tests-integration/src/test/java/org/apache/wayang/tests/platform/MyMadeUpPlatform.java	54