Path Lines of Code python/old_code/tests/__init__.py 1 python/old_code/tests/demo_testing.py 8 python/old_code/tests/full_java_test.py 26 python/old_code/tests/full_spark_test.py 33 python/src/pywy/tests/__init__.py 1 python/src/pywy/tests/benchmark/__init__.py 1 python/src/pywy/tests/benchmark/python_benchmark_test.py 51 python/src/pywy/tests/integration/__init__.py 1 python/src/pywy/tests/integration/jvm_platform_test.py 61 python/src/pywy/tests/integration/python_platform_test.py 93 python/src/pywy/tests/unit/__init__.py 1 python/src/pywy/tests/unit/core/__init__.py 1 python/src/pywy/tests/unit/core/channel_test.py 6 python/src/pywy/tests/unit/core/executor_test.py 6 python/src/pywy/tests/unit/core/mapping_test.py 6 python/src/pywy/tests/unit/core/plan_test.py 6 python/src/pywy/tests/unit/core/platform_test.py 10 python/src/pywy/tests/unit/core/plugin_test.py 6 python/src/pywy/tests/unit/core/translator_test.py 6 python/src/pywy/tests/unit/dataquanta/__init__.py 1 python/src/pywy/tests/unit/dataquanta/context_test.py 69 python/src/pywy/tests/unit/dataquanta/dataquanta_test.py 106 python/src/pywy/tests/unit/graph/__init__.py 1 python/src/pywy/tests/unit/graph/graph_test.py 6 python/src/pywy/tests/unit/graph/types_test.py 6 python/src/pywy/tests/unit/operators/__init__.py 1 python/src/pywy/tests/unit/operators/base_test.py 6 python/src/pywy/tests/unit/operators/sink_test.py 6 python/src/pywy/tests/unit/operators/source_test.py 6 python/src/pywy/tests/unit/operators/unary_test.py 6 python/src/pywy/tests/unit/platforms/__init__.py 1 python/src/pywy/tests/unit/platforms/python/__init__.py 1 python/src/pywy/tests/unit/platforms/python/channel_test.py 6 python/src/pywy/tests/unit/platforms/python/execution_test.py 6 python/src/pywy/tests/unit/platforms/python/mappings_test.py 6 python/src/pywy/tests/unit/platforms/python/operator/__init__.py 1 python/src/pywy/tests/unit/platforms/python/operator/py_execution_operator_test.py 6 python/src/pywy/tests/unit/platforms/python/operator/py_sink_textfile_test.py 6 python/src/pywy/tests/unit/platforms/python/operator/py_source_textfile_test.py 6 python/src/pywy/tests/unit/platforms/python/operator/py_unary_filter_test.py 6 python/src/pywy/tests/unit/platforms/python/platform_test.py 6 python/src/pywy/tests/unit/platforms/python/plugin_test.py 6 python/src/pywy/tests/unit/types_test.py 203 wayang-api/wayang-api-python/src/test/java/org/apache/wayang/api/python/PythonAPITest.java 4 wayang-api/wayang-api-scala-java/code/test/java/org/apache/wayang/api/JavaApiTest.java 538 wayang-api/wayang-api-scala-java/code/test/scala/org/apache/wayang/api/ApiTest.scala 399 wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlAPI.java 100 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 77 wayang-benchmark/code/test/java/org/apache/wayang/apps/tpch/data/LineItemTupleTest.java 42 wayang-benchmark/code/test/resources/kmeans-datagenerator.py 26 wayang-benchmark/code/test/scala/org/apache/wayang/apps/kmeans/KmeansTest.scala 46 wayang-benchmark/code/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/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/code/test/java/org/apache/wayang/flink/operators/FlinkCartesianOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkCoGroupOperatorTest.java 83 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkCollectionSourceTest.java 24 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkCountOperatorTest.java 28 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkDistinctOperatorTest.java 26 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkFilterOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkFlatMapOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperatorTest.java 56 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkJoinOperatorTest.java 44 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperatorTest.java 36 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperatorTest.java 61 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkOperatorTestBase.java 60 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkReduceByOperatorTest.java 62 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkSortOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/operators/FlinkUnionAllOperatorTest.java 27 wayang-platforms/wayang-flink/code/test/java/org/apache/wayang/flink/test/ChannelFactory.java 43 wayang-platforms/wayang-giraph/src/test/java/org/apache/wayang/giraph/operators/GiraphPagaRankOperatorTest.java 56 wayang-platforms/wayang-graphchi/src/test/java/org/apache/wayang/graphchi/operators/GraphChiPageRankOperatorTest.java 57 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/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 68 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-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/JdbcTableSourceTest.java 45 wayang-platforms/wayang-jdbc-template/src/test/java/org/apache/wayang/jdbc/operators/OperatorTestBase.java 42 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/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/code/test/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperatorTest.java 42 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkCartesianOperatorTest.java 27 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkCoGroupOperatorTest.java 88 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkCollectionSourceTest.java 24 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkCountOperatorTest.java 24 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkDistinctOperatorTest.java 24 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkFilterOperatorTest.java 27 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkFlatMapOperatorTest.java 27 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperatorTest.java 42 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperatorTest.java 56 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkJoinOperatorTest.java 44 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperatorTest.java 33 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperatorTest.java 54 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkObjectFileSinkTest.java 45 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkObjectFileSourceTest.java 45 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkOperatorTestBase.java 59 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperatorTest.java 46 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkReduceByOperatorTest.java 56 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperatorTest.java 49 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkSortOperatorTest.java 27 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkTextFileSinkTest.java 28 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/operators/SparkUnionAllOperatorTest.java 26 wayang-platforms/wayang-spark/code/test/java/org/apache/wayang/spark/test/ChannelFactory.java 43 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/JavaExecutionOperatorTestBase.java 55 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperatorTest.java 55 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest.java 52 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest2.java 54 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest3.java 54 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperatorTest4.java 54 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperatorTest.java 42 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/operators/SparkOperatorTestBase.java 61 wayang-plugins/wayang-iejoin/code/test/java/org/apache/wayang/iejoin/test/ChannelFactory.java 58 wayang-tests-integration/code/test/java/org/apache/wayang/tests/FlinkIntegrationIT.java 337 wayang-tests-integration/code/test/java/org/apache/wayang/tests/FullIntegrationIT.java 385 wayang-tests-integration/code/test/java/org/apache/wayang/tests/GiraphIntegrationIT.java 39 wayang-tests-integration/code/test/java/org/apache/wayang/tests/JavaIntegrationIT.java 356 wayang-tests-integration/code/test/java/org/apache/wayang/tests/PostgresIntegrationIT.java 43 wayang-tests-integration/code/test/java/org/apache/wayang/tests/RegressionIT.java 37 wayang-tests-integration/code/test/java/org/apache/wayang/tests/SparkIntegrationIT.java 309 wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlans.java 695 wayang-tests-integration/code/test/java/org/apache/wayang/tests/WayangPlansOperators.java 274 wayang-tests-integration/code/test/java/org/apache/wayang/tests/WordCountIT.java 316 wayang-tests-integration/code/test/java/org/apache/wayang/tests/platform/MyMadeUpPlatform.java 54 wayang-tests-integration/pom.xml 208 wayang-tests-integration/wayang-tests-integration_2.11/pom.xml 86 wayang-tests-integration/wayang-tests-integration_2.11/src/test/java/org/apache/wayang/test/GraphChiIntegrationIT.java 64 wayang-tests-integration/wayang-tests-integration_2.12/pom.xml 68 wayang-web-dashboard/dashboard-webapp/src/main/vue/cypress/e2e/example.cy.js 6 wayang-web-dashboard/dashboard-webapp/src/main/vue/src/components/__tests__/HelloWorld.spec.js 9