Path	Lines of Code
python/old_code/orchestrator/dataquanta.py	219
python/old_code/orchestrator/execdirectly.py	85
python/old_code/orchestrator/main.py	87
python/old_code/orchestrator/operator.py	72
python/src/pywy/core/core.py	69
python/src/pywy/platforms/jvm/execution.py	55
python/src/pywy/platforms/jvm/operator/jvm_unary_filter.py	42
python/src/pywy/platforms/jvm/worker.py	205
python/src/pywy/platforms/python/execution.py	59
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java	108
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessReceiver.java	24
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonProcessCaller.java	85
wayang-api/wayang-api-rest/src/main/java/org/apache/wayang/api/rest/server/spring/decoder/WayangPlanBuilder.java	160
wayang-api/wayang-api-rest/src/main/java/org/apache/wayang/api/rest/server/spring/general/WayangController.java	206
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/DataQuanta.scala	424
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala	682
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala	49
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/PlanBuilder.scala	60
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala	34
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/graph/package.scala	9
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/package.scala	99
wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala	49
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java	67
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java	49
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java	403
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java	172
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java	123
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java	124
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java	139
wayang-benchmark/code/main/java/org/apache/wayang/apps/tpch/Main.java	105
wayang-benchmark/code/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala	123
wayang-benchmark/code/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala	122
wayang-benchmark/code/main/scala/org/apache/wayang/apps/util/ProfileDBHelper.scala	15
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java	107
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java	226
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/RepeatMapping.java	69
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java	67
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DistinctOperator.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalReduceOperator.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/IntersectOperator.java	32
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/JoinOperator.java	67
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MaterializedGroupByOperator.java	44
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java	92
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceByOperator.java	58
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java	97
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java	552
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/AggregationDescriptor.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/HttpMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/ZeroMQMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java	93
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/AbstractAlternativeCardinalityPusher.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/AggregatingCardinalityEstimator.java	21
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java	629
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java	80
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java	305
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java	401
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java	666
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java	690
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java	549
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java	153
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java	117
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java	82
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Subplan.java	181
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CardinalityBreakpoint.java	73
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java	604
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/NoIterationBreakpoint.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Platform.java	68
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java	94
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java	97
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/PartialExecutionMeasurement.java	30
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileSystems.java	75
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/HadoopFileSystem.java	93
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java	95
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java	221
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/JDBCStorage.java	47
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/Storage.java	63
wayang-docs/src/main/resources/_layouts/default.html	64
wayang-docs/src/main/resources/assets/css/color.css	44
wayang-platforms/wayang-flink/code/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java	105
wayang-platforms/wayang-flink/code/main/java/org/apache/wayang/flink/mapping/SampleMapping.java	41
wayang-platforms/wayang-flink/code/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java	75
wayang-platforms/wayang-flink/code/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java	149
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/execution/JavaExecutor.java	93
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaDoWhileOperator.java	123
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaLoopOperator.java	137
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSink.java	98
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSource.java	104
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/graph/JavaPageRankOperator.java	98
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java	156
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java	52
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/execution/SparkExecutor.java	115
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/mapping/SampleMapping.java	57
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkCoGroupOperator.java	101
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java	131
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java	104
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java	146
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java	72
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java	206
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkReduceByOperator.java	103
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkRepeatOperator.java	91
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkTsvFileSink.java	75
wayang-platforms/wayang-spark/code/main/java/org/apache/wayang/spark/operators/SparkTsvFileSource.java	79
wayang-plugins/wayang-iejoin/code/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java	158
wayang-plugins/wayang-iejoin/code/main/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperator.java	123
wayang-profiler/code/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java	201
wayang-profiler/code/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java	481