Path	Lines of Code
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