Path	Lines of Code
guides/WordCount.java	34
guides/pom-example.xml	68
python/pyproject.toml	19
python/setup.cfg	28
python/src/pywy/__init__.py	1
python/src/pywy/basic/__init__.py	1
python/src/pywy/basic/data/__init__.py	1
python/src/pywy/basic/data/record.py	31
python/src/pywy/basic/model/__init__.py	1
python/src/pywy/basic/model/models.py	8
python/src/pywy/basic/model/ops.py	157
python/src/pywy/basic/model/optimizer.py	33
python/src/pywy/basic/model/option.py	28
python/src/pywy/core/__init__.py	7
python/src/pywy/core/core.py	56
python/src/pywy/core/functions.py	11
python/src/pywy/core/platform.py	8
python/src/pywy/core/serializer.py	76
python/src/pywy/dataquanta.py	154
python/src/pywy/exception.py	2
python/src/pywy/execution/__init__.py	1
python/src/pywy/execution/util.py	7
python/src/pywy/execution/worker.py	91
python/src/pywy/graph/__init__.py	1
python/src/pywy/graph/graph.py	58
python/src/pywy/graph/types.py	37
python/src/pywy/operators/__init__.py	27
python/src/pywy/operators/base.py	66
python/src/pywy/operators/binary.py	59
python/src/pywy/operators/sink.py	24
python/src/pywy/operators/source.py	44
python/src/pywy/operators/unary.py	127
python/src/pywy/platforms/__init__.py	1
python/src/pywy/platforms/java.py	6
python/src/pywy/platforms/python.py	6
python/src/pywy/platforms/spark.py	6
python/src/pywy/platforms/tensorflow.py	6
python/src/pywy/types.py	154
src/main/script/prerequisiteCheck.groovy	143
wayang-api/wayang-api-json/src/main/scala/Main.scala	49
wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala	503
wayang-api/wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala	2
wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala	14
wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala	83
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ComposedOperatorFromJson.scala	11
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala	44
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala	135
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala	37
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CartesianOperatorFromJson.scala	12
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala	68
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala	12
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/UnionOperatorFromJson.scala	12
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/InputCollectionFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/JDBCRemoteInputFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala	20
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TableInputFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala	20
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/loop/DoWhileOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/loop/ForeachOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/loop/RepeatOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/other/KMeansFromJson.scala	21
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/output/TextFileOutputFromJson.scala	20
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/CountOperatorFromJson.scala	12
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/DistinctOperatorFromJson.scala	12
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/FilterOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/FlatMapOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/MapOperatorFromJson.scala	21
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/MapPartitionsOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/ReduceByOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/ReduceOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/SampleOperatorFromJson.scala	16
wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/SortOperatorFromJson.scala	17
wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromDrawflow.scala	33
wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromJson.scala	31
wayang-api/wayang-api-json/src/main/scala/parserutil/ParsePlanFromJson.scala	25
wayang-api/wayang-api-json/src/main/scala/parserutil/ParsingErrors.scala	11
wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableIterable.scala	22
wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableLambda.scala	23
wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableLambda2.scala	22
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java	5
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java	103
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	75
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonWorkerManager.java	31
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ReaderIterator.java	53
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedFlatMapDescriptor.java	31
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedMapPartitionsDescriptor.java	24
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPredicateDescriptor.java	35
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPythonFunction.java	16
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedReduceDescriptor.java	30
wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java	28
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala	610
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala	721
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala	61
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContext.scala	41
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextDataQuanta.scala	66
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextPlanBuilder.scala	76
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala	73
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuanta.scala	19
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala	34
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaAsyncResult.scala	4
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaImplicits.scala	30
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/Main.scala	39
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/PlanBuilderImplicits.scala	11
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/package.scala	63
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/Edge.scala	4
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/EdgeDataQuanta.scala	16
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/EdgeDataQuantaBuilder.scala	32
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/package.scala	9
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala	100
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/SerializationUtils.scala	165
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/TempFileUtils.scala	38
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableDeserializer.scala	12
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableSerializer.scala	12
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/MultiContextDeserializer.scala	54
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/MultiContextSerializer.scala	29
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/OperatorDeserializer.scala	286
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala	22
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformSerializer.scala	9
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ConfigurationAndContextMixIns.scala	75
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DataTypeMixIns.scala	41
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DescriptorMixIns.scala	88
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/EstimatorMixIns.scala	90
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/IgnoreLoggerMixIn.scala	7
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/OperatorMixIns.scala	102
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ProviderMixIns.scala	56
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/SlotMixIns.scala	20
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala	14
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala	49
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala	30
wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/TypeTrap.scala	17
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/convention/WayangConvention.java	37
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java	60
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java	33
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java	29
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java	52
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java	88
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java	25
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java	38
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java	10
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java	48
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java	50
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java	38
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java	92
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateGetResult.java	38
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java	19
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java	116
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java	14
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java	20
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java	12
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/MultiConditionJoinFuncImpl.java	22
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/MultiConditionJoinKeyExtractor.java	14
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java	86
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java	18
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java	30
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/jdbc/JdbcTable.java	177
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java	193
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java	179
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/WayangProgram.java	28
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangAggregate.java	32
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangFilter.java	25
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangJoin.java	36
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangProject.java	31
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangRel.java	4
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java	32
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangTableScan.java	64
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java	149
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangSortRule.java	32
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java	20
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangSchema.java	25
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangSchemaBuilder.java	27
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTable.java	40
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTableBuilder.java	43
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTableStatistic.java	40
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java	66
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/PrintUtils.java	30
wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java	79
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-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java	9
wayang-applications/src/main/java/org/apache/wayang/applications/Util.java	7
wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java	46
wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java	62
wayang-assembly/dependency-reduced-pom.xml	162
wayang-benchmark/src/main/java/org/apache/wayang/apps/grep/Grep.java	110
wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImpl.java	177
wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImprovedImpl.java	117
wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Random16.java	294
wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Unsigned16.java	191
wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/TPCHQ1WithJavaNative.java	104
wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java	133
wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/GroupKey.java	25
wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java	52
wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java	65
wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java	38
wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java	52
wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountWithJavaNativeAPI.java	105
wayang-benchmark/src/main/scala/org/apache/wayang/apps/benchmark/OptimizerScalabilityTest.scala	37
wayang-benchmark/src/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala	42
wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CreateInitialPageRanks.scala	13
wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala	83
wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala	123
wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala	122
wayang-benchmark/src/main/scala/org/apache/wayang/apps/sgd/SGD.scala	44
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/AddIdFunction.scala	7
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/CreateWordNeighborhoodFunction.scala	33
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/ResolveClusterFunction.scala	13
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/ScrubFunction.scala	14
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala	33
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SimWords.scala	116
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SparseVector.scala	130
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/TextScrubber.scala	8
wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala	98
wayang-benchmark/src/main/scala/org/apache/wayang/apps/sindy/Sindy.scala	127
wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraApp.scala	79
wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala	82
wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraSort.scala	21
wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraValidate.scala	69
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/CsvUtils.scala	9
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/SqlUtils.scala	5
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/TpcH.scala	90
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/data/Customer.scala	25
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/data/LineItem.scala	62
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/data/Order.scala	38
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala	92
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala	95
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3File.scala	84
wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Hybrid.scala	94
wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/ExperimentDescriptor.scala	8
wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala	70
wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/ProfileDBHelper.scala	15
wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/StdOut.scala	13
wayang-benchmark/src/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala	61
wayang-benchmark/src/main/scala/org/apache/wayang/async/apps/WordCount.scala	42
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/package.scala	23
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/tpch/Query1.scala	79
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCount.scala	30
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCountCombineEach.scala	36
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCountWithMerge.scala	37
wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCountWithTargetPlatforms.scala	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/WayangBasics.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java	139
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java	96
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java	56
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/GlobalReduceMapping.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/Mappings.java	14
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java	41
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/ReduceByMapping.java	52
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/model/DLModel.java	11
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java	4
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/KMeansModel.java	5
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/LinearRegressionModel.java	5
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/Model.java	4
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/ArgMax.java	19
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Cast.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Eq.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Mean.java	26
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java	51
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/CrossEntropyLoss.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Linear.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/ReLU.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Sigmoid.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Softmax.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Adam.java	33
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/GradientDescent.java	9
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Optimizer.java	21
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java	188
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java	185
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CartesianOperator.java	34
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/CollectionSource.java	46
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CountOperator.java	26
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java	59
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java	15
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/DoWhileOperator.java	168
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FilterOperator.java	62
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FlatMapOperator.java	63
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java	25
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/GoogleCloudStorageSource.java	163
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GroupByOperator.java	30
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/KMeansOperator.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java	126
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java	177
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LinearRegressionOperator.java	29
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LocalCallbackSink.java	73
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java	194
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MapOperator.java	56
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/MapPartitionsOperator.java	63
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/ModelTransformOperator.java	38
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java	26
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/PageRankOperator.java	64
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java	125
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperator.java	20
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PredictOperators.java	13
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PyWayangReduceByOperator.java	34
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/ReduceOperator.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java	130
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java	96
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SortOperator.java	40
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TableSource.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSink.java	43
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java	121
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/UnionAllOperator.java	33
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ZipWithIdOperator.java	30
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/plugin/WayangBasic.java	37
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/plugin/WayangBasicGraph.java	27
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/types/RecordType.java	44
wayang-commons/wayang-core/src/main/antlr4/org/apache/wayang/core/mathex/MathEx.g4	61
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java	621
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java	545
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/CollectionProvider.java	29
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ConstantValueProvider.java	25
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ExplicitCollectionProvider.java	47
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalCollectionProvider.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalKeyValueProvider.java	34
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalValueProvider.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java	68
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/MapBasedKeyValueProvider.java	44
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/ValueProvider.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/exception/WayangException.java	17
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/function/ConsumerDescriptor.java	55
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExecutionContext.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExtendedFunction.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FlatMapDescriptor.java	73
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java	76
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/PredicateDescriptor.java	64
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ReduceDescriptor.java	51
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java	74
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/Mapping.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorMatch.java	16
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorPattern.java	100
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java	110
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/ReplacementSubplanFactory.java	67
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/SubplanMatch.java	67
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/SubplanPattern.java	100
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/DisabledMonitor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/FileMonitor.java	61
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/Monitor.java	21
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/AggregateOptimizationContext.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/DefaultOptimizationContext.java	169
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java	452
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationUtils.java	84
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java	86
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/cardinality/CardinalityEstimate.java	59
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java	256
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java	130
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityPusher.java	50
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimator.java	76
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityPusher.java	43
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FallbackCardinalityEstimator.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopHeadAlternativeCardinalityPusher.java	40
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/LoopSubplanCardinalityPusher.java	78
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java	35
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusher.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SwitchForwardCardinalityEstimator.java	28
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversion.java	49
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/channels/DefaultChannelConversion.java	143
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/ConstantLoadProfileEstimator.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java	244
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultLoadEstimator.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCost.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCostFactory.java	4
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimationContext.java	77
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/IntervalLoadEstimator.java	99
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java	48
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimator.java	50
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java	120
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimator.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java	281
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileToTimeConverter.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadToTimeConverter.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimator.java	129
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/costs/TimeEstimate.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/TimeToCostConverter.java	26
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlow.java	97
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/LatentOperatorPruningStrategy.java	61
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopEnumerator.java	102
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LoopImplementation.java	142
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/PlanEnumerationPruningStrategy.java	6
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	665
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/RandomPruningStrategy.java	23
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/SinglePlatformPruningStrategy.java	15
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/optimizer/enumeration/TopKPruningStrategy.java	23
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationAlternative.java	3
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationBranch.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java	249
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ChannelInitializer.java	16
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/executionplan/ExecutionStage.java	233
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStageLoop.java	45
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionTask.java	135
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/PlatformExecution.java	40
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ActualOperator.java	7
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/BinaryToUnaryOperator.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/CompositeOperator.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ElementaryOperator.java	17
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/EstimationContextProperty.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java	148
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java	119
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadAlternative.java	101
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadOperator.java	46
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/LoopSubplan.java	53
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java	270
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java	216
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java	233
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java	111
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java	83
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operators.java	89
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OutputSlot.java	116
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanMetrics.java	63
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java	180
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java	54
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java	185
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/plan/wayangplan/TopDownPlanVisitor.java	36
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java	25
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySource.java	22
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnaryToUnaryOperator.java	30
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java	111
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/traversal/AbstractTopologicalTraversal.java	91
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AbstractChannelInstance.java	58
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java	101
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java	95
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Breakpoint.java	11
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/ChannelDescriptor.java	63
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ChannelInstance.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CompositeExecutionResource.java	5
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ConjunctiveBreakpoint.java	25
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/ExecutionResource.java	6
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutionResourceTemplate.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutionState.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Executor.java	14
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java	118
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/FixBreakpoint.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java	135
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/PartialExecution.java	134
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/PushExecutorTemplate.java	222
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/ChannelLineageNode.java	28
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/ExecutionLineageNode.java	39
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/plugin/DynamicPlugin.java	198
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/Plugin.java	32
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java	143
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CostMeasurement.java	34
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionLog.java	90
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java	169
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/FullInstrumentationStrategy.java	12
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/InstrumentationStrategy.java	7
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/NoInstrumentationStrategy.java	9
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/OutboundInstrumentationStrategy.java	9
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/profiling/ProfileDBs.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java	41
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java	69
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitGroupType.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java	27
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/AbstractReferenceCountable.java	43
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Action.java	13
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Actions.java	6
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java	260
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Canonicalizer.java	104
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ConsumerIteratorAdapter.java	110
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Copyable.java	4
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Counter.java	57
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/CrossProductIterable.java	62
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainTreeNode.java	58
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java	142
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Formats.java	37
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Iterators.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializable.java	31
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializables.java	115
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializer.java	20
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JuelUtils.java	74
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/LimitedInputStream.java	65
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Logging.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/LruCache.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/MultiMap.java	17
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/OneTimeExecutable.java	18
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Optional.java	41
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReferenceCountable.java	10
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java	282
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Tuple.java	39
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/TypeConverter.java	13
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangArrays.java	52
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangCollections.java	146
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/FileSystem.java	16
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/FileUtils.java	56
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/fs/LocalFileSystem.java	150
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java	194
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java	97
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java	223
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/Context.java	8
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/DefaultContext.java	69
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/Expression.java	22
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/ExpressionBuilder.java	80
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/EvaluationException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/MathExException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/ParseException.java	19
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/BinaryOperation.java	48
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/CompiledFunction.java	47
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/Constant.java	24
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/NamedFunction.java	44
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/UnaryOperation.java	27
wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/Variable.java	17
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/ProfileDB.java	70
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/instrumentation/StopWatch.java	79
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/json/MeasurementDeserializer.java	29
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/json/MeasurementSerializer.java	15
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java	90
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Measurement.java	33
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Subject.java	34
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Type.java	10
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java	102
wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/FileStorage.java	44
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/_includes/footer.html	38
wayang-docs/src/main/resources/_includes/head.html	44
wayang-docs/src/main/resources/_includes/scripts.html	20
wayang-docs/src/main/resources/_includes/sub-menu.html	51
wayang-docs/src/main/resources/_layouts/default.html	64
wayang-docs/src/main/resources/_sass/main.scss	8
wayang-docs/src/main/resources/assets/css/color.css	44
wayang-docs/src/main/resources/assets/css/main.css	103
wayang-docs/src/main/resources/assets/css/monokai.css	92
wayang-docs/src/main/resources/assets/js/add_numbers.js	12
wayang-docs/src/main/resources/assets/js/menu.js	7
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Compute.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/LocalStage.java	5
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/LogicalOperator.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Loop.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Sample.java	9
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Transform.java	5
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Update.java	7
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/UpdateLocal.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allModel.java	22
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allPlan.java	125
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/Platforms.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AggregateWrapper.java	13
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AssignWrapper.java	18
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AssignWrapperLocal.java	17
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ComputePerPartitionWrapper.java	20
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ComputeWrapper.java	14
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/LogicalOperatorWrapper.java	6
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/LogicalOperatorWrapperWithModel.java	25
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/LoopCheckWrapper.java	14
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/LoopConvergenceWrapper.java	14
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ReduceWrapper.java	18
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/TransformPerPartitionWrapper.java	16
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/TransformWrapper.java	12
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/UpdateLocalWrapper.java	15
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/UpdateWrapper.java	15
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansCompute.java	36
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansConvergeOrMaxIterationsLoop.java	31
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansStageWithZeros.java	18
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansUpdate.java	27
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/TransformCSV.java	20
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/ComputeLogisticGradient.java	29
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/LibSVMTransform.java	24
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDLoop.java	25
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDSample.java	17
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDStageWithZeros.java	15
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/WeightsUpdate.java	33
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/SparseVector.java	172
wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/StringUtil.java	45
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/Flink.java	22
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/ChannelConversions.java	49
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataSetChannel.java	65
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java	10
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java	125
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java	19
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java	23
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java	25
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java	282
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java	20
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyMap.java	24
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java	26
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangFilterCriterion.java	20
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangListValue.java	11
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java	102
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java	56
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutionContext.java	31
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java	107
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CartesianMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CoGroupMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CollectionSourceMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CountMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/DistinctMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java	37
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java	36
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FlatMapMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/GlobalMaterializedGroupMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/GlobalReduceMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/GroupByMapping.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/IntersectMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/JoinMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/LocalCallbackSinkMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/LoopMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/MapMapping.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/MapPartitionsMapping.java	36
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/Mappings.java	37
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/MaterializedGroupByMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSinkMapping.java	38
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSourceMapping.java	41
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/PageRankMapping.java	32
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ReduceByMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/RepeatMapping.java	35
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SampleMapping.java	41
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SortMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/TextFileSinkMapping.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/TextFileSourceMapping.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/UnionAllMapping.java	34
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ZipWithIdMapping.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java	43
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java	73
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java	111
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java	75
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java	100
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCountOperator.java	66
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java	63
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java	155
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkExecutionOperator.java	25
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java	68
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java	112
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperator.java	74
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java	82
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java	89
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java	89
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java	103
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java	69
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLoopOperator.java	123
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMapOperator.java	107
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMapPartitionsOperator.java	113
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkMaterializedGroupByOperator.java	89
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java	78
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java	99
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java	167
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java	87
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java	149
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java	102
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java	97
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSortOperator.java	70
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java	60
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSource.java	69
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java	77
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java	62
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java	70
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java	33
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java	126
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkBasicPlugin.java	30
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkConversionPlugin.java	29
wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java	6
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/GenericJdbc.java	17
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/channels/GenericChannelConversions.java	18
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/execution/GenericJdbcExecutor.java	153
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/FilterMapping.java	35
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/Mappings.java	10
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/ProjectionMapping.java	44
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcExecutionOperator.java	9
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcFilterOperator.java	17
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcProjectionOperator.java	21
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericJdbcTableSource.java	58
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/operators/GenericSqlToStreamOperator.java	153
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/platform/GenericJdbcPlatform.java	42
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/plugin/GenericJdbcConversionsPlugin.java	30
wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/plugin/GenericJdbcPlugin.java	30
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankAlgorithm.java	183
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankParameters.java	37
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java	12
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/channels/ChannelConversions.java	8
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/execution/GiraphExecutor.java	77
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/mappings/Mappings.java	9
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/mappings/PageRankMapping.java	32
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/operators/GiraphExecutionOperator.java	14
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/operators/GiraphPageRankOperator.java	147
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/platform/GiraphPlatform.java	56
wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/plugin/GiraphPlugin.java	34
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/Java.java	22
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/ChannelConversions.java	59
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/CollectionChannel.java	58
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/JavaChannelInstance.java	7
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/StreamChannel.java	71
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/compiler/FunctionCompiler.java	34
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/execution/JavaExecutionContext.java	35
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/mapping/AmazonS3SourceMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AzureBlobStorageSourceMapping.java	34
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/CartesianMapping.java	30
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/CoGroupMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/CollectionSourceMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/CountMapping.java	31
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/DistinctMapping.java	30
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/DoWhileMapping.java	38
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/FilterMapping.java	36
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/FlatMapMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GlobalMaterializedGroupMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GlobalReduceMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GoogleCloudStorageSourceMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/IntersectMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/JoinMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/KafkaTopicSinkMapping.java	29
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/KafkaTopicSourceMapping.java	29
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/LocalCallbackSinkMapping.java	32
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/LoopMapping.java	34
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/MapMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/MapPartitionsMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java	45
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/MaterializedGroupByMapping.java	32
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSinkMapping.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java	40
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java	32
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ReduceByMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/RepeatMapping.java	34
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SampleMapping.java	53
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SortMapping.java	32
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/TextFileSinkMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/TextFileSourceMapping.java	32
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/UnionAllMapping.java	33
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ZipWithIdMapping.java	59
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/graph/PageRankMapping.java	30
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java	70
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAzureBlobStorageSource.java	70
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCartesianOperator.java	123
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCoGroupOperator.java	119
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectOperator.java	58
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCollectionSource.java	52
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCountOperator.java	63
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaDistinctOperator.java	56
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/JavaExecutionOperator.java	35
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFilterOperator.java	76
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFlatMapOperator.java	86
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGlobalMaterializedGroupOperator.java	60
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGlobalReduceOperator.java	72
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java	74
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaIntersectOperator.java	99
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaJoinOperator.java	139
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java	98
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSource.java	79
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaLocalCallbackSink.java	54
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/JavaMapOperator.java	76
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMapPartitionsOperator.java	85
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMaterializedGroupByOperator.java	78
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSink.java	133
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSource.java	164
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java	115
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java	101
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReduceByOperator.java	131
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRepeatOperator.java	90
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReservoirSampleOperator.java	90
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java	60
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSink.java	83
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java	104
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/JavaUnionAllOperator.java	60
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/graph/JavaPageRankOperator.java	98
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/platform/JavaPlatform.java	53
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/plugin/JavaBasicPlugin.java	29
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/plugin/JavaChannelConversionPlugin.java	27
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/plugin/JavaGraphPlugin.java	28
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/channels/SqlQueryChannel.java	72
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/compiler/FunctionCompiler.java	10
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/DatabaseDescriptor.java	27
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java	177
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcExecutionOperator.java	22
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcFilterOperator.java	33
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcJoinOperator.java	54
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcProjectionOperator.java	49
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcTableSource.java	57
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToRddOperator.java	76
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java	159
wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/platform/JdbcPlatformTemplate.java	72
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/Postgres.java	17
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/channels/ChannelConversions.java	26
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/FilterMapping.java	35
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/JoinMapping.java	49
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/Mappings.java	11
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/ProjectionMapping.java	44
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresExecutionOperator.java	9
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresFilterOperator.java	17
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresJoinOperator.java	20
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresProjectionOperator.java	21
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/operators/PostgresTableSource.java	17
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/platform/PostgresPlatform.java	21
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/plugin/PostgresConversionsPlugin.java	30
wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/plugin/PostgresPlugin.java	30
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/Spark.java	27
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java	52
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/ChannelConversions.java	87
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/FileChannels.java	4
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/RddChannel.java	92
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/BinaryOperatorAdapter.java	13
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedBinaryOperatorAdapter.java	23
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedFlatMapFunctionAdapter.java	25
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedFunction.java	23
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedMapFunctionAdapter.java	23
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedMapPartitionsFunctionAdapter.java	32
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedPredicateAdapater.java	22
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FlatMapFunctionAdapter.java	13
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java	128
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/MapFunctionAdapter.java	12
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java	24
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/PredicateAdapter.java	13
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkContextReference.java	23
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java	47
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java	118
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/CartesianMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/CoGroupMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/CollectionSourceMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/CountMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/DistinctMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/DoWhileMapping.java	37
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/FilterMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/FlatMapMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/GlobalMaterializedGroupMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/GlobalReduceMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/IntersectMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/JoinMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSinkMapping.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSourceMapping.java	28
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/LocalCallbackSinkMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/LoopMapping.java	35
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/MapMapping.java	36
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/MapPartitionsMapping.java	36
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java	50
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/MaterializedGroupByMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSinkMapping.java	40
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSourceMapping.java	42
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ParquetSourceMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ReduceByMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/RepeatMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SampleMapping.java	57
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SortMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/TextFileSinkMapping.java	35
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/TextFileSourceMapping.java	34
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/UnionAllMapping.java	33
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ZipWithIdMapping.java	32
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/graph/PageRankMapping.java	42
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/DecisionTreeClassificationMapping.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/KMeansMapping.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/LinearRegressionMapping.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/ModelTransformMapping.java	31
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/PredictMapping.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/model/SparkMLModel.java	11
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/Application.java	17
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/Executor.java	22
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/Job.java	16
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/SerializableObject.java	4
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/Stage.java	30
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/Task.java	38
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/interfaces/TaskMetric.java	26
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationEnd.java	61
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationStart.java	61
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorAdded.java	82
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorRemoved.java	82
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ExecutorUpdated.java	82
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/JobEnd.java	53
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/JobStart.java	53
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java	375
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java	113
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageExecutorMetrics.java	110
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageSubmitted.java	111
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java	149
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java	147
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskMetric.java	110
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskStart.java	147
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java	77
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBroadcastOperator.java	64
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCacheOperator.java	66
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCartesianOperator.java	71
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCoGroupOperator.java	101
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCollectOperator.java	66
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCollectionSource.java	75
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCountOperator.java	60
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDistinctOperator.java	62
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java	131
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkExecutionOperator.java	37
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java	77
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFlatMapOperator.java	83
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java	81
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalReduceOperator.java	83
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkIntersectOperator.java	66
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java	104
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSink.java	83
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java	78
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLocalCallbackSink.java	59
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java	146
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkMapOperator.java	83
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperator.java	89
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkMaterializedGroupByOperator.java	90
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java	72
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSource.java	75
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java	74
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java	207
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkReduceByOperator.java	103
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRepeatOperator.java	91
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java	166
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkSortOperator.java	74
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTextFileSink.java	65
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTextFileSource.java	70
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTsvFileSink.java	75
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTsvFileSource.java	79
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkUnionAllOperator.java	64
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkZipWithIdOperator.java	75
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/Attr.java	6
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkDecisionTreeClassificationOperator.java	119
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkKMeansOperator.java	101
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java	124
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java	62
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkPredictOperator.java	60
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/platform/SparkPlatform.java	169
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/plugin/SparkBasicPlugin.java	30
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/plugin/SparkConversionPlugin.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/plugin/SparkGraphPlugin.java	29
wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/plugin/SparkMLPlugin.java	27
wayang-platforms/wayang-spark/src/main/scala/org/apache/wayang/spark/operators/graph/SparkPageRankOperator.scala	58
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/Sqlite3.java	17
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/channels/ChannelConversions.java	27
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/FilterMapping.java	36
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/Mappings.java	10
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/ProjectionMapping.java	39
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3FilterOperator.java	18
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3ProjectionOperator.java	21
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3TableSource.java	22
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/platform/Sqlite3Platform.java	21
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/plugin/Sqlite3ConversionPlugin.java	29
wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/plugin/Sqlite3Plugin.java	30
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/Tensorflow.java	17
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/channels/ChannelConversions.java	26
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/channels/TensorChannel.java	69
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowContextReference.java	25
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowExecutor.java	79
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/mapping/CollectionSourceMapping.java	29
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/mapping/DLTrainingOperatorMapping.java	29
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/mapping/Mappings.java	11
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/mapping/PredictMapping.java	29
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/Convertor.java	205
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java	130
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectOperator.java	257
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectionSource.java	177
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowDLTrainingOperator.java	56
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowExecutionOperator.java	22
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowPredictOperator.java	55
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/platform/TensorflowPlatform.java	60
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/plugin/TensorflowConversionPlugin.java	29
wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/plugin/TensorflowPlugin.java	30
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java	82
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/data/Data.java	94
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/Mappings.java	17
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/java/IEJoinMapping.java	34
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/java/IESelfJoinMapping.java	37
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/spark/IEJoinMapping.java	37
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/spark/IESelfJoinMapping.java	36
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IEJoinMasterOperator.java	44
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IEJoinOperator.java	73
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IESelfJoinOperator.java	60
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java	107
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java	87
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java	158
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperator.java	123
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java	188
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java	53
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/extractData.java	18
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/myMergeSort.java	60
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java	65
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java	182
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/List2AttributesObjectSkinny.java	49
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/addUniqueID.java	31
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/build2ListObject.java	45
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/extractData.java	18
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/filterUnwantedBlocks.java	44
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/myMergeSort.java	55
wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/revDataComparator.java	61
wayang-profiler/src/main/java/org/apache/wayang/profiler/data/DataGenerators.java	57
wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java	94
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/BinaryOperatorProfiler.java	46
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/JavaCollectionSourceProfiler.java	25
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/JavaTextFileSourceProfiler.java	33
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java	140
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java	253
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/Profiler.java	272
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/SinkProfiler.java	33
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/SourceProfiler.java	36
wayang-profiler/src/main/java/org/apache/wayang/profiler/java/UnaryOperatorProfiler.java	37
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicEstimationContext.java	35
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadEstimator.java	161
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimator.java	75
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimators.java	95
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java	201
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java	481
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Individual.java	172
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/LogEvaluator.java	181
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/OptimizationSpace.java	43
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Variable.java	57
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/sampling/Battle.java	5
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/sampling/ReservoirSampler.java	33
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/sampling/Sampler.java	6
wayang-profiler/src/main/java/org/apache/wayang/profiler/log/sampling/TournamentSampler.java	41
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/BinaryOperatorProfiler.java	58
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/Main.java	137
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java	322
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SinkProfiler.java	43
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkCollectionSourceProfiler.java	39
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java	262
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkSourceProfiler.java	40
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkTextFileSourceProfiler.java	63
wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkUnaryOperatorProfiler.java	48
wayang-profiler/src/main/java/org/apache/wayang/profiler/util/ProfilingUtils.java	32
wayang-profiler/src/main/java/org/apache/wayang/profiler/util/RrdAccessor.java	71
wayang-resources/src/main/assembly/resources.xml	14
wayang-resources/src/main/resources/assemblies/resources.xml	15