apache / incubator-wayang
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,055 files with 68,462 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 7 files changed 21-50 times (1,556 lines of code)
    • 419 files changed 6-20 times (29,940 lines of code)
    • 629 files changed 1-5 times (36,966 lines of code)
0% | 0% | 2% | 43% | 53%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,055 files with 68,462 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 18 files changed by 11-25 contributors (2,998 lines of code)
    • 357 files changed by 6-10 contributors (26,086 lines of code)
    • 582 files changed by 2-5 contributors (34,805 lines of code)
    • 98 files changed by 1 contributor (4,573 lines of code)
0% | 4% | 38% | 50% | 6%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, scala, md, py, xml, properties, sh, json, yaml, html, gitignore, svg, css, js, scss, cfg, toml, g4, txt, groovy, gitmodules, cmd
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
scala0% | 0% | 16% | 39% | 44%
java0% | 0% | <1% | 43% | 56%
py0% | 0% | 11% | 72% | 15%
xml0% | 0% | 0% | 88% | 11%
groovy0% | 0% | 0% | 100% | 0%
html0% | 0% | 0% | 47% | 52%
cfg0% | 0% | 0% | 100% | 0%
css0% | 0% | 0% | 0% | 100%
g40% | 0% | 0% | 0% | 100%
toml0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
scss0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
wayang-api0% | 0% | 15% | 45% | 38%
python0% | 0% | 11% | 72% | 16%
wayang-commons0% | 0% | <1% | 21% | 78%
wayang-platforms0% | 0% | 0% | 56% | 43%
wayang-profiler0% | 0% | 0% | 100% | 0%
wayang-plugins0% | 0% | 0% | 100% | 0%
wayang-benchmark0% | 0% | 0% | 13% | 86%
wayang-ml4all0% | 0% | 0% | 54% | 45%
wayang-assembly0% | 0% | 0% | 100% | 0%
src0% | 0% | 0% | 100% | 0%
wayang-docs0% | 0% | 0% | 21% | 78%
guides0% | 0% | 0% | 66% | 33%
wayang-applications0% | 0% | 0% | 0% | 100%
wayang-resources0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DataQuanta.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 610 45 2021-02-09 2025-05-04 35 15 ro.pardo.meza@gmail.com 72268582+aurb9@users.norepl...
JsonPlanBuilder.scala
in wayang-api/wayang-api-json/src/main/scala/builder
 503 39 2024-03-11 2025-05-06 26 6 juri@hey.com zkaoudi@users.noreply.githu...
PlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 73 7 2021-02-09 2025-05-06 22 14 ro.pardo.meza@gmail.com zkaoudi@users.noreply.githu...
dataquanta.py
in python/src/pywy
 154 23 2022-04-06 2025-05-06 22 9 bertty@databloom.ai zkaoudi@users.noreply.githu...
WayangRelConverter.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 38 4 2023-04-15 2025-05-04 21 17 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
SqlContext.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context
 79 5 2023-04-15 2025-05-04 21 18 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangContext.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 99 18 2021-02-09 2024-08-23 21 12 ro.pardo.meza@gmail.com mirko.kaempf@gmail.com
serializer.py
in python/src/pywy/core
 76 3 2024-04-16 2025-05-06 19 7 juri@hey.com zkaoudi@users.noreply.githu...
JavaPlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 61 6 2021-02-09 2025-05-06 18 13 ro.pardo.meza@gmail.com zkaoudi@users.noreply.githu...
JavaTextFileSource.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 104 6 2020-12-18 2025-04-10 18 11 bertty@scalytics.io aurb@itu.dk
WayangProjectVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 25 1 2023-04-15 2025-05-04 17 16 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangTableScanVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 50 1 2023-04-15 2025-05-04 17 15 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangAggregateVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 60 1 2023-10-05 2025-05-04 17 11 adityagoel11082002@gmail.com 72268582+aurb9@users.norepl...
unary.py
in python/src/pywy/operators
 127 29 2022-04-07 2025-05-06 17 7 bertty@databloom.ai zkaoudi@users.noreply.githu...
Job.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 545 31 2021-02-09 2024-02-06 17 14 ro.pardo.meza@gmail.com juri@hey.com
binary.py
in python/src/pywy/operators
 59 8 2024-04-18 2025-05-06 16 7 juri@hey.com zkaoudi@users.noreply.githu...
base.py
in python/src/pywy/operators
 66 9 2022-04-07 2025-05-06 16 9 bertty@databloom.ai zkaoudi@users.noreply.githu...
OperatorFromJson.scala
in wayang-api/wayang-api-json/src/main/scala/operatorfromjson
 135 4 2024-03-11 2025-05-06 16 6 juri@hey.com zkaoudi@users.noreply.githu...
DataQuantaBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 721 59 2021-02-09 2025-04-10 16 12 ro.pardo.meza@gmail.com aurb@itu.dk
Mappings.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping
 50 - 2020-12-18 2025-04-03 15 11 bertty@scalytics.io zkaoudi@users.noreply.githu...
core.py
in python/src/pywy/core
 56 6 2022-04-11 2025-05-06 15 7 berttycontreras@gmail.com zkaoudi@users.noreply.githu...
types.py
in python/src/pywy
 154 12 2022-04-06 2025-05-06 15 7 bertty@databloom.ai zkaoudi@users.noreply.githu...
__init__.py
in python/src/pywy/operators
 27 - 2022-04-07 2025-05-06 14 7 bertty@databloom.ai zkaoudi@users.noreply.githu...
Main.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount
 65 1 2021-09-05 2025-04-10 14 13 atroudi@hbku.edu.qa aurb@itu.dk
TensorflowModel.java
in wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model
 130 9 2024-03-26 2025-04-10 14 7 2789706336@qq.com aurb@itu.dk
Configuration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 621 62 2021-02-09 2024-08-23 14 10 ro.pardo.meza@gmail.com aloalt@apache.org
Mappings.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 45 - 2020-12-18 2025-04-10 13 9 bertty@scalytics.io aurb@itu.dk
WayangJoinVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 52 1 2023-04-15 2025-05-04 13 13 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
OperatorFromDrawflowConverter.scala
in wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow
 83 3 2024-03-11 2025-05-06 13 6 juri@hey.com zkaoudi@users.noreply.githu...
FlinkPlatform.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform
 126 6 2020-12-18 2025-04-10 13 10 bertty@scalytics.io aurb@itu.dk
KeySelectorFunction.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 23 3 2020-12-18 2025-04-10 12 9 bertty@scalytics.io aurb@itu.dk
cfg
setup.cfg
in python
 28 - 2022-04-01 2024-08-23 12 6 bertty@databloom.ai mirko.kaempf@gmail.com
WordCount.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount
 38 1 2024-03-20 2025-04-10 12 11 zkaoudi@yahoo.gr aurb@itu.dk
source.py
in python/src/pywy/operators
 44 10 2022-04-07 2025-05-06 12 7 bertty@databloom.ai zkaoudi@users.noreply.githu...
SparkBernoulliSampleOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators
 77 7 2020-12-18 2024-08-23 12 8 bertty@scalytics.io mirko.kaempf@gmail.com
SparkKMeansOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml
 101 9 2024-01-10 2025-04-10 12 9 juri.petersen@visuellverste... aurb@itu.dk
KafkaTopicSink.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 126 10 2024-02-12 2025-04-10 12 6 mirko.kaempf@gmail.com aurb@itu.dk
SqlToStreamOperator.java
in wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators
 159 12 2020-12-18 2024-02-06 12 6 bertty@scalytics.io juri@hey.com
SparkShufflePartitionSampleOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators
 166 9 2020-12-18 2024-08-23 12 8 bertty@scalytics.io mirko.kaempf@gmail.com
Optimizer.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer
 179 11 2023-04-15 2025-04-10 12 11 kbeedkar@gmail.com aurb@itu.dk
SparkRandomPartitionSampleOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators
 207 9 2020-12-18 2024-08-23 12 8 bertty@scalytics.io mirko.kaempf@gmail.com
GeneticOptimizerApp.java
in wayang-profiler/src/main/java/org/apache/wayang/profiler/log
 481 14 2020-12-18 2024-02-06 12 7 bertty@scalytics.io juri@hey.com
MapOperatorFromJson.scala
in wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary
 21 - 2024-03-11 2024-08-23 11 5 juri@hey.com mirko.kaempf@gmail.com
MapPartitionsFunctionAdapter.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler
 24 2 2020-12-18 2024-08-23 11 8 bertty@scalytics.io mirko.kaempf@gmail.com
sink.py
in python/src/pywy/operators
 24 7 2022-04-07 2025-05-06 11 7 bertty@databloom.ai zkaoudi@users.noreply.githu...
WayangFilterVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 29 1 2023-04-15 2025-05-04 11 9 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
FlinkTextFileSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 60 6 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkDistinctOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 63 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkFilterOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 68 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkTextFileSource.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 69 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SqlContext.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context
 79 5 2023-04-15 2025-05-04 21 18 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangRelConverter.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 38 4 2023-04-15 2025-05-04 21 17 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangProjectVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 25 1 2023-04-15 2025-05-04 17 16 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
DataQuanta.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 610 45 2021-02-09 2025-05-04 35 15 ro.pardo.meza@gmail.com 72268582+aurb9@users.norepl...
WayangTableScanVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 50 1 2023-04-15 2025-05-04 17 15 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
PlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 73 7 2021-02-09 2025-05-06 22 14 ro.pardo.meza@gmail.com zkaoudi@users.noreply.githu...
Job.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 545 31 2021-02-09 2024-02-06 17 14 ro.pardo.meza@gmail.com juri@hey.com
JavaPlanBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 61 6 2021-02-09 2025-05-06 18 13 ro.pardo.meza@gmail.com zkaoudi@users.noreply.githu...
Main.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount
 65 1 2021-09-05 2025-04-10 14 13 atroudi@hbku.edu.qa aurb@itu.dk
WayangJoinVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 52 1 2023-04-15 2025-05-04 13 13 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
WayangContext.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 99 18 2021-02-09 2024-08-23 21 12 ro.pardo.meza@gmail.com mirko.kaempf@gmail.com
DataQuantaBuilder.scala
in wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api
 721 59 2021-02-09 2025-04-10 16 12 ro.pardo.meza@gmail.com aurb@itu.dk
JavaTextFileSource.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 104 6 2020-12-18 2025-04-10 18 11 bertty@scalytics.io aurb@itu.dk
WayangAggregateVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 60 1 2023-10-05 2025-05-04 17 11 adityagoel11082002@gmail.com 72268582+aurb9@users.norepl...
Mappings.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping
 50 - 2020-12-18 2025-04-03 15 11 bertty@scalytics.io zkaoudi@users.noreply.githu...
Optimizer.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer
 179 11 2023-04-15 2025-04-10 12 11 kbeedkar@gmail.com aurb@itu.dk
WordCount.java
in wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount
 38 1 2024-03-20 2025-04-10 12 11 zkaoudi@yahoo.gr aurb@itu.dk
WayangRules.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules
 149 8 2023-04-15 2025-05-04 10 11 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
Configuration.java
in wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api
 621 62 2021-02-09 2024-08-23 14 10 ro.pardo.meza@gmail.com aloalt@apache.org
FlinkPlatform.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform
 126 6 2020-12-18 2025-04-10 13 10 bertty@scalytics.io aurb@itu.dk
JdbcExecutor.java
in wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution
 177 8 2020-12-18 2025-05-04 11 10 bertty@scalytics.io 72268582+aurb9@users.norepl...
dataquanta.py
in python/src/pywy
 154 23 2022-04-06 2025-05-06 22 9 bertty@databloom.ai zkaoudi@users.noreply.githu...
base.py
in python/src/pywy/operators
 66 9 2022-04-07 2025-05-06 16 9 bertty@databloom.ai zkaoudi@users.noreply.githu...
Mappings.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 45 - 2020-12-18 2025-04-10 13 9 bertty@scalytics.io aurb@itu.dk
KeySelectorFunction.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler
 23 3 2020-12-18 2025-04-10 12 9 bertty@scalytics.io aurb@itu.dk
SparkKMeansOperator.java
in wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml
 101 9 2024-01-10 2025-04-10 12 9 juri.petersen@visuellverste... aurb@itu.dk
WayangFilterVisitor.java
in wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter
 29 1 2023-04-15 2025-05-04 11 9 kbeedkar@gmail.com 72268582+aurb9@users.norepl...
FlinkRepeatExpandedOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 149 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkObjectFileSource.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 99 9 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkRepeatOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 102 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkSortOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 70 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkGroupByOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 89 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkCoGroupOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 111 10 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkGlobalReduceOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 82 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkFilterOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 68 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkLocalCallbackSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 69 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkDistinctOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 63 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkMapOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 107 9 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkTextFileSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 60 6 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkMapPartitionsOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 113 10 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkCollectionSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 75 6 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkTsvFileSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 77 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkObjectFileSink.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 78 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkJoinOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 103 9 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkReduceByOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 87 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkCartesianOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 73 7 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkCollectionSource.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 100 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkFlatMapOperator.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 112 10 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkTextFileSource.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators
 69 8 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
FlinkExecutor.java
in wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution
 107 6 2020-12-18 2025-04-10 11 9 bertty@scalytics.io aurb@itu.dk
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
JavaJoinOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 139 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaLoopOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 137 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaReduceByOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 131 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaDoWhileOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 123 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaCartesianOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 123 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaCoGroupOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 119 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaTsvFileSource.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 104 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaIntersectOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 99 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaTsvFileSink.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 98 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaExecutor.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/execution
 93 5 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ObjectFileSource.java
in wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators
 92 8 2022-03-18 2022-03-18 1 1 bertty@databloom.ai bertty@databloom.ai
JavaRepeatOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 90 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaFlatMapOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 86 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaMapPartitionsOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 85 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaTextFileSink.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 83 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaMaterializedGroupByOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 78 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
GiraphExecutor.java
in wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/execution
 77 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaFilterOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 76 8 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaMapOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 76 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaGlobalReduceOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 72 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
StreamChannel.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels
 71 11 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaCountOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 63 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaUnionAllOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 60 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaGlobalMaterializedGroupOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 60 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ChannelConversions.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels
 59 - 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ZipWithIdMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 59 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
CollectionChannel.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels
 58 10 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaCollectOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 58 5 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
GiraphPlatform.java
in wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/platform
 56 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaDistinctOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 56 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaLocalCallbackSink.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 54 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
SampleMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 53 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaCollectionSource.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 52 6 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JdbcProjectionOperator.java
in wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators
 49 7 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ProjectionMapping.java
in wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping
 44 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ObjectFileSourceMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 40 3 2022-03-18 2022-03-18 1 1 bertty@databloom.ai bertty@databloom.ai
ProjectionMapping.java
in wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping
 39 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
DoWhileMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 38 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
PageRankParameters.java
in wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm
 37 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
FilterMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 36 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
FilterMapping.java
in wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping
 36 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaExecutionOperator.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators
 35 2 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
CoGroupMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 35 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
ObjectFileSinkMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 35 3 2022-03-18 2022-03-18 1 1 bertty@databloom.ai bertty@databloom.ai
FlatMapMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 35 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
GlobalMaterializedGroupMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 35 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
JavaExecutionContext.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/execution
 35 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
FilterMapping.java
in wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping
 35 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
GiraphPlugin.java
in wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/plugin
 34 4 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
LoopMapping.java
in wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping
 34 3 2020-12-18 2021-02-06 3 1 bertty@scalytics.io bertty@scalytics.io
Correlations

File Size vs. Number of Changes: 1055 points

python/src/pywy/basic/data/__init__.py x: 1 lines of code y: 2 # changes python/src/pywy/basic/data/record.py x: 31 lines of code y: 4 # changes python/src/pywy/core/core.py x: 56 lines of code y: 15 # changes python/src/pywy/core/serializer.py x: 76 lines of code y: 19 # changes python/src/pywy/dataquanta.py x: 154 lines of code y: 22 # changes python/src/pywy/execution/util.py x: 7 lines of code y: 5 # changes python/src/pywy/execution/worker.py x: 91 lines of code y: 9 # changes python/src/pywy/graph/graph.py x: 58 lines of code y: 6 # changes python/src/pywy/operators/__init__.py x: 27 lines of code y: 14 # changes python/src/pywy/operators/base.py x: 66 lines of code y: 16 # changes python/src/pywy/operators/binary.py x: 59 lines of code y: 16 # changes python/src/pywy/operators/sink.py x: 24 lines of code y: 11 # changes python/src/pywy/operators/source.py x: 44 lines of code y: 12 # changes python/src/pywy/operators/unary.py x: 127 lines of code y: 17 # changes python/src/pywy/types.py x: 154 lines of code y: 15 # changes wayang-api/wayang-api-json/src/main/scala/Main.scala x: 49 lines of code y: 9 # changes wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 503 lines of code y: 26 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 83 lines of code y: 13 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 44 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 135 lines of code y: 16 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 37 lines of code y: 5 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 12 lines of code y: 9 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 17 lines of code y: 9 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 20 lines of code y: 4 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOperatorFromJson.scala x: 16 lines of code y: 2 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java x: 28 lines of code y: 8 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 61 lines of code y: 18 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 73 lines of code y: 22 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 30 lines of code y: 5 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 96 lines of code y: 7 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 610 lines of code y: 35 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 60 lines of code y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 33 lines of code y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 29 lines of code y: 11 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 52 lines of code y: 13 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 88 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 25 lines of code y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 38 lines of code y: 21 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 10 lines of code y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 48 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 50 lines of code y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 38 lines of code y: 5 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 92 lines of code y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 19 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 116 lines of code y: 5 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 14 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 20 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinKeyExtractor.java x: 12 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/MultiConditionJoinFuncImpl.java x: 22 lines of code y: 2 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/MultiConditionJoinKeyExtractor.java x: 14 lines of code y: 2 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 86 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 18 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 30 lines of code y: 2 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 32 lines of code y: 2 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 149 lines of code y: 10 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangSortRule.java x: 32 lines of code y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 79 lines of code y: 21 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 74 lines of code y: 6 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 60 lines of code y: 5 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 177 lines of code y: 11 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 721 lines of code y: 16 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 179 lines of code y: 12 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 66 lines of code y: 9 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 65 lines of code y: 14 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 38 lines of code y: 12 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 52 lines of code y: 5 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 188 lines of code y: 7 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 185 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 163 lines of code y: 6 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 126 lines of code y: 12 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java x: 125 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 270 lines of code y: 5 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 125 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 23 lines of code y: 12 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 107 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java x: 43 lines of code y: 4 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 73 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 111 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 75 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 100 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 63 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFilterOperator.java x: 68 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkFlatMapOperator.java x: 112 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 82 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 89 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 103 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 69 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 78 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 87 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 149 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatOperator.java x: 102 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 60 lines of code y: 11 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 33 lines of code y: 4 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java x: 126 lines of code y: 13 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 35 lines of code y: 6 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AzureBlobStorageSourceMapping.java x: 34 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GoogleCloudStorageSourceMapping.java x: 35 lines of code y: 5 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 45 lines of code y: 13 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java x: 32 lines of code y: 4 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 70 lines of code y: 6 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAzureBlobStorageSource.java x: 70 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 98 lines of code y: 11 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 115 lines of code y: 4 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 104 lines of code y: 18 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 74 lines of code y: 4 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkKMeansOperator.java x: 101 lines of code y: 12 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 130 lines of code y: 14 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 118 lines of code y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java x: 50 lines of code y: 15 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ParquetSourceMapping.java x: 34 lines of code y: 2 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 62 lines of code y: 8 # changes wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 9 lines of code y: 4 # changes wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 7 lines of code y: 3 # changes wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 46 lines of code y: 4 # changes wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java x: 62 lines of code y: 3 # changes wayang-assembly/dependency-reduced-pom.xml x: 162 lines of code y: 7 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 78 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/tpch/Query1.scala x: 79 lines of code y: 7 # changes wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCount.scala x: 30 lines of code y: 7 # changes wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCountWithMerge.scala x: 37 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java x: 10 lines of code y: 8 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java x: 19 lines of code y: 8 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java x: 25 lines of code y: 8 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java x: 20 lines of code y: 8 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyMap.java x: 24 lines of code y: 8 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java x: 33 lines of code y: 8 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java x: 177 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java x: 621 lines of code y: 14 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java x: 78 lines of code y: 10 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java x: 74 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java x: 78 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticIntervalEstimate.java x: 86 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimate.java x: 59 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java x: 10 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/DefaultCardinalityEstimator.java x: 76 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java x: 48 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java x: 120 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java x: 119 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java x: 216 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java x: 233 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java x: 111 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java x: 83 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java x: 54 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java x: 185 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java x: 25 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java x: 41 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java x: 69 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java x: 27 lines of code y: 4 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/KafkaTopicSinkMapping.java x: 29 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSource.java x: 79 lines of code y: 6 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSinkMapping.java x: 29 lines of code y: 2 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSourceMapping.java x: 28 lines of code y: 2 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSink.java x: 83 lines of code y: 2 # changes python/pyproject.toml x: 19 lines of code y: 5 # changes python/setup.cfg x: 28 lines of code y: 12 # changes python/src/pywy/basic/__init__.py x: 1 lines of code y: 3 # changes python/src/pywy/basic/model/ops.py x: 157 lines of code y: 6 # changes python/src/pywy/basic/model/optimizer.py x: 33 lines of code y: 5 # changes python/src/pywy/basic/model/option.py x: 28 lines of code y: 5 # changes python/src/pywy/core/__init__.py x: 7 lines of code y: 9 # changes python/src/pywy/core/functions.py x: 11 lines of code y: 3 # changes python/src/pywy/platforms/java.py x: 6 lines of code y: 3 # changes wayang-api/wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala x: 2 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala x: 14 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ComposedOperatorFromJson.scala x: 11 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CartesianOperatorFromJson.scala x: 12 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala x: 16 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala x: 68 lines of code y: 8 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala x: 17 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala x: 20 lines of code y: 9 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/other/KMeansFromJson.scala x: 21 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/FlatMapOperatorFromJson.scala x: 17 lines of code y: 10 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/MapOperatorFromJson.scala x: 21 lines of code y: 11 # changes wayang-api/wayang-api-json/src/main/scala/parserutil/ParseOperatorsFromDrawflow.scala x: 33 lines of code y: 7 # changes wayang-api/wayang-api-json/src/main/scala/parserutil/ParsePlanFromJson.scala x: 25 lines of code y: 3 # changes wayang-api/wayang-api-json/src/main/scala/parserutil/ParsingErrors.scala x: 11 lines of code y: 4 # changes wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableIterable.scala x: 22 lines of code y: 4 # changes wayang-api/wayang-api-json/src/main/scala/parserutil/SerializableLambda.scala x: 23 lines of code y: 4 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java x: 103 lines of code y: 9 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessReceiver.java x: 24 lines of code y: 7 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonProcessCaller.java x: 75 lines of code y: 7 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonWorkerManager.java x: 31 lines of code y: 9 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ReaderIterator.java x: 53 lines of code y: 7 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedFlatMapDescriptor.java x: 31 lines of code y: 3 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedMapPartitionsDescriptor.java x: 24 lines of code y: 5 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPythonFunction.java x: 16 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextDataQuanta.scala x: 66 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextPlanBuilder.scala x: 76 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaAsyncResult.scala x: 4 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaImplicits.scala x: 30 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/Main.scala x: 39 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/PlanBuilderImplicits.scala x: 11 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/package.scala x: 63 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala x: 100 lines of code y: 9 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/SerializationUtils.scala x: 165 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableDeserializer.scala x: 12 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/MultiContextSerializer.scala x: 29 lines of code y: 4 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/OperatorDeserializer.scala x: 286 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala x: 22 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformSerializer.scala x: 9 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ConfigurationAndContextMixIns.scala x: 75 lines of code y: 6 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DataTypeMixIns.scala x: 41 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/DescriptorMixIns.scala x: 88 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/EstimatorMixIns.scala x: 90 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/OperatorMixIns.scala x: 102 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ProviderMixIns.scala x: 56 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/SlotMixIns.scala x: 20 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala x: 70 lines of code y: 9 # changes wayang-benchmark/src/main/scala/org/apache/wayang/async/apps/WordCount.scala x: 42 lines of code y: 6 # changes wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/package.scala x: 23 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCountCombineEach.scala x: 36 lines of code y: 6 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/SampleOperator.java x: 96 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java x: 99 lines of code y: 21 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java x: 130 lines of code y: 7 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultLoadEstimator.java x: 99 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimator.java x: 50 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java x: 281 lines of code y: 10 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/NestableLoadProfileEstimator.java x: 129 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java x: 604 lines of code y: 7 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java x: 282 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java x: 97 lines of code y: 11 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java x: 101 lines of code y: 8 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReservoirSampleOperator.java x: 90 lines of code y: 8 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToRddOperator.java x: 76 lines of code y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java x: 128 lines of code y: 11 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java x: 77 lines of code y: 12 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java x: 207 lines of code y: 12 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java x: 166 lines of code y: 12 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTextFileSource.java x: 70 lines of code y: 10 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectionSource.java x: 177 lines of code y: 7 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java x: 4 lines of code y: 7 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/KMeansModel.java x: 5 lines of code y: 8 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/ArgMax.java x: 19 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java x: 37 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java x: 51 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/CrossEntropyLoss.java x: 27 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/Linear.java x: 38 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/nn/ReLU.java x: 21 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/Adam.java x: 33 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/optimizer/GradientDescent.java x: 9 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java x: 59 lines of code y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java x: 15 lines of code y: 7 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LinearRegressionOperator.java x: 29 lines of code y: 7 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ModelTransformOperator.java x: 38 lines of code y: 9 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/model/SparkMLModel.java x: 11 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkDecisionTreeClassificationOperator.java x: 119 lines of code y: 7 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java x: 124 lines of code y: 7 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java x: 62 lines of code y: 7 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkPredictOperator.java x: 60 lines of code y: 3 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/execution/TensorflowExecutor.java x: 79 lines of code y: 3 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/Convertor.java x: 205 lines of code y: 3 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectOperator.java x: 257 lines of code y: 3 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowDLTrainingOperator.java x: 56 lines of code y: 3 # changes wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowPredictOperator.java x: 55 lines of code y: 3 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/TPCHQ1WithJavaNative.java x: 104 lines of code y: 3 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountWithJavaNativeAPI.java x: 105 lines of code y: 3 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala x: 61 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainTreeNode.java x: 58 lines of code y: 2 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java x: 142 lines of code y: 4 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Compute.java x: 6 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/Update.java x: 7 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allPlan.java x: 125 lines of code y: 9 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AssignWrapper.java x: 18 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/ComputePerPartitionWrapper.java x: 20 lines of code y: 7 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansCompute.java x: 36 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansConvergeOrMaxIterationsLoop.java x: 31 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansUpdate.java x: 27 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/ComputeLogisticGradient.java x: 29 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDStageWithZeros.java x: 15 lines of code y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java x: 143 lines of code y: 9 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java x: 97 lines of code y: 5 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java x: 223 lines of code y: 5 # changes guides/pom-example.xml x: 68 lines of code y: 6 # changes python/src/pywy/__init__.py x: 1 lines of code y: 4 # changes python/src/pywy/exception.py x: 2 lines of code y: 3 # changes src/main/script/prerequisiteCheck.groovy x: 143 lines of code y: 10 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/graph/EdgeDataQuantaBuilder.scala x: 32 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala x: 14 lines of code y: 5 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala x: 49 lines of code y: 7 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/TypeTrap.scala x: 17 lines of code y: 5 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/convention/WayangConvention.java x: 37 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java x: 403 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcTable.java x: 177 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java x: 193 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/WayangProgram.java x: 28 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangJoin.java x: 36 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangRel.java x: 4 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangTableScan.java x: 64 lines of code y: 8 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTable.java x: 40 lines of code y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java x: 124 lines of code y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java x: 139 lines of code y: 6 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/grep/Grep.java x: 110 lines of code y: 4 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImpl.java x: 177 lines of code y: 5 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Random16.java x: 294 lines of code y: 4 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Unsigned16.java x: 191 lines of code y: 4 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java x: 133 lines of code y: 5 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/GroupKey.java x: 25 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala x: 42 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala x: 83 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/Kmeans.scala x: 123 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala x: 122 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/sgd/SGD.scala x: 44 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SparseVector.scala x: 130 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala x: 98 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/sindy/Sindy.scala x: 127 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraApp.scala x: 79 lines of code y: 4 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/data/LineItem.scala x: 62 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala x: 92 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala x: 95 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3File.scala x: 84 lines of code y: 5 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/ProfileDBHelper.scala x: 15 lines of code y: 5 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java x: 545 lines of code y: 17 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java x: 244 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimatableCost.java x: 24 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java x: 665 lines of code y: 7 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/TypeConverter.java x: 13 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java x: 194 lines of code y: 3 # changes wayang-docs/src/main/resources/_includes/footer.html x: 38 lines of code y: 8 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/LogicalOperator.java x: 6 lines of code y: 5 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/SparseVector.java x: 172 lines of code y: 5 # changes wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/StringUtil.java x: 45 lines of code y: 5 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataSetChannel.java x: 65 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java x: 282 lines of code y: 9 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java x: 102 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java x: 56 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/CartesianMapping.java x: 34 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java x: 36 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/ObjectFileSinkMapping.java x: 38 lines of code y: 4 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/PageRankMapping.java x: 32 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SampleMapping.java x: 41 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCountOperator.java x: 66 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java x: 155 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkExecutionOperator.java x: 25 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalMaterializedGroupOperator.java x: 74 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java x: 89 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLoopOperator.java x: 123 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java x: 167 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java x: 70 lines of code y: 7 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java x: 6 lines of code y: 7 # changes wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/GenericJdbc.java x: 17 lines of code y: 4 # changes wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/execution/GenericJdbcExecutor.java x: 153 lines of code y: 4 # changes wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/mapping/FilterMapping.java x: 35 lines of code y: 4 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/channels/SqlQueryChannel.java x: 72 lines of code y: 7 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java x: 159 lines of code y: 12 # changes wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/JoinMapping.java x: 49 lines of code y: 4 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java x: 52 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/ChannelConversions.java x: 87 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/RddChannel.java x: 92 lines of code y: 9 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/BinaryOperatorAdapter.java x: 13 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedBinaryOperatorAdapter.java x: 23 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedMapPartitionsFunctionAdapter.java x: 32 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/ExtendedPredicateAdapater.java x: 22 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java x: 47 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/DoWhileMapping.java x: 37 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/FilterMapping.java x: 34 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ObjectFileSinkMapping.java x: 40 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SampleMapping.java x: 57 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/graph/PageRankMapping.java x: 42 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/ml/KMeansMapping.java x: 29 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/JobEnd.java x: 53 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java x: 375 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java x: 113 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageExecutorMetrics.java x: 110 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageSubmitted.java x: 111 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java x: 149 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java x: 147 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCacheOperator.java x: 66 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCartesianOperator.java x: 71 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkCollectionSource.java x: 75 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java x: 131 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java x: 77 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFlatMapOperator.java x: 83 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java x: 81 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java x: 104 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLocalCallbackSink.java x: 59 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java x: 146 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkMapPartitionsOperator.java x: 89 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java x: 72 lines of code y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSource.java x: 75 lines of code y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTsvFileSource.java x: 79 lines of code y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/Attr.java x: 6 lines of code y: 4 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/platform/SparkPlatform.java x: 169 lines of code y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/plugin/SparkMLPlugin.java x: 27 lines of code y: 5 # changes wayang-platforms/wayang-spark/src/main/scala/org/apache/wayang/spark/operators/graph/SparkPageRankOperator.scala x: 58 lines of code y: 8 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java x: 82 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/data/Data.java x: 94 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/Mappings.java x: 17 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/java/IESelfJoinMapping.java x: 37 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IEJoinMasterOperator.java x: 44 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/IESelfJoinOperator.java x: 60 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java x: 107 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java x: 87 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java x: 158 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIESelfJoinOperator.java x: 123 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java x: 188 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/DataComparator.java x: 53 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java x: 65 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java x: 182 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/List2AttributesObjectSkinny.java x: 49 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/build2ListObject.java x: 45 lines of code y: 6 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/myMergeSort.java x: 55 lines of code y: 6 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/hardware/DiskProfiler.java x: 94 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/java/BinaryOperatorProfiler.java x: 46 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java x: 140 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java x: 253 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/java/Profiler.java x: 272 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/java/SourceProfiler.java x: 36 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadEstimator.java x: 161 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/DynamicLoadProfileEstimators.java x: 95 lines of code y: 10 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java x: 201 lines of code y: 8 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java x: 481 lines of code y: 12 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Individual.java x: 172 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/log/LogEvaluator.java x: 181 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/BinaryOperatorProfiler.java x: 58 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/Main.java x: 137 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java x: 322 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkCollectionSourceProfiler.java x: 39 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java x: 262 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkSourceProfiler.java x: 40 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkTextFileSourceProfiler.java x: 63 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkUnaryOperatorProfiler.java x: 48 lines of code y: 7 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/util/ProfilingUtils.java x: 32 lines of code y: 9 # changes wayang-profiler/src/main/java/org/apache/wayang/profiler/util/RrdAccessor.java x: 71 lines of code y: 9 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/platform/JdbcPlatformTemplate.java x: 72 lines of code y: 6 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java x: 26 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java x: 92 lines of code y: 1 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSinkMapping.java x: 35 lines of code y: 1 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java x: 40 lines of code y: 1 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSink.java x: 133 lines of code y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java x: 93 lines of code y: 4 # changes wayang-docs/src/main/resources/_includes/head.html x: 44 lines of code y: 3 # changes wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/json/MeasurementSerializer.java x: 15 lines of code y: 3 # changes wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java x: 90 lines of code y: 3 # changes wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Type.java x: 10 lines of code y: 3 # changes wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java x: 102 lines of code y: 3 # changes wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/Storage.java x: 63 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/EstimationContext.java x: 77 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java x: 80 lines of code y: 4 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java x: 101 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java x: 95 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PartialExecution.java x: 134 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Platform.java x: 68 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/JsonSerializables.java x: 115 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/graph/JavaPageRankOperator.java x: 98 lines of code y: 4 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java x: 121 lines of code y: 5 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java x: 401 lines of code y: 5 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java x: 666 lines of code y: 5 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java x: 169 lines of code y: 3 # changes wayang-docs/src/main/resources/_sass/main.scss x: 8 lines of code y: 2 # changes wayang-docs/src/main/resources/assets/css/color.css x: 44 lines of code y: 2 # changes wayang-docs/src/main/resources/assets/css/main.css x: 103 lines of code y: 5 # changes wayang-docs/src/main/resources/assets/css/monokai.css x: 92 lines of code y: 2 # changes wayang-docs/src/main/resources/assets/js/add_numbers.js x: 12 lines of code y: 2 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java x: 110 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java x: 452 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityPusher.java x: 50 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SwitchForwardCardinalityEstimator.java x: 28 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java x: 629 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlow.java x: 97 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java x: 305 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java x: 549 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java x: 249 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java x: 148 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java x: 82 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java x: 180 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java x: 111 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AbstractChannelInstance.java x: 58 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CardinalityBreakpoint.java x: 73 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java x: 118 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java x: 135 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/HadoopFileSystem.java x: 93 lines of code y: 3 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/LocalFileSystem.java x: 150 lines of code y: 3 # changes wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankAlgorithm.java x: 183 lines of code y: 5 # changes wayang-resources/src/main/resources/assemblies/resources.xml x: 15 lines of code y: 2 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java x: 5 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/WayangBasics.java x: 13 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java x: 139 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java x: 38 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java x: 56 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java x: 107 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/GlobalReduceMapping.java x: 43 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/Mappings.java x: 14 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java x: 41 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java x: 226 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/ReduceByMapping.java x: 52 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/RepeatMapping.java x: 69 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CoGroupOperator.java x: 67 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/CollectionSource.java x: 46 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DistinctOperator.java x: 27 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DoWhileOperator.java x: 168 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FilterOperator.java x: 62 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/FlatMapOperator.java x: 63 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GroupByOperator.java x: 30 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/IntersectOperator.java x: 32 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LocalCallbackSink.java x: 73 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java x: 194 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/PageRankOperator.java x: 64 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceByOperator.java x: 58 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ReduceOperator.java x: 37 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java x: 130 lines of code y: 1 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/UnionAllOperator.java x: 33 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/antlr4/org/apache/wayang/core/mathex/MathEx.g4 x: 61 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalCollectionProvider.java x: 24 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/FunctionalValueProvider.java x: 20 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/exception/WayangException.java x: 17 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ConsumerDescriptor.java x: 55 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/ExecutionContext.java x: 8 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/MapPartitionsDescriptor.java x: 76 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorMatch.java x: 16 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/OperatorPattern.java x: 100 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/monitor/Monitor.java x: 21 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/AggregateOptimizationContext.java x: 78 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationUtils.java x: 84 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java x: 256 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/SubplanCardinalityPusher.java x: 54 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversion.java x: 49 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/DefaultChannelConversion.java x: 143 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerationPruningStrategy.java x: 6 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/RandomPruningStrategy.java x: 23 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/SinglePlatformPruningStrategy.java x: 15 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/partition/EnumerationAlternative.java x: 3 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java x: 233 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStageLoop.java x: 45 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionTask.java x: 135 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ActualOperator.java x: 7 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/CompositeOperator.java x: 10 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopHeadAlternative.java x: 101 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopSubplan.java x: 53 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operators.java x: 89 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OutputSlot.java x: 116 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Subplan.java x: 181 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/TopDownPlanVisitor.java x: 36 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Breakpoint.java x: 11 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java x: 222 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/ChannelLineageNode.java x: 28 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java x: 198 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java x: 260 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Canonicalizer.java x: 104 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ConsumerIteratorAdapter.java x: 110 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/WayangCollections.java x: 146 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/ExpressionBuilder.java x: 80 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/exceptions/EvaluationException.java x: 19 lines of code y: 1 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/mathex/model/BinaryOperation.java x: 48 lines of code y: 1 # changes wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/FilterMapping.java x: 36 lines of code y: 3 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcProjectionOperator.java x: 49 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/StreamChannel.java x: 71 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SampleMapping.java x: 53 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCartesianOperator.java x: 123 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCoGroupOperator.java x: 119 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFilterOperator.java x: 76 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGlobalReduceOperator.java x: 72 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaIntersectOperator.java x: 99 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaJoinOperator.java x: 139 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaLocalCallbackSink.java x: 54 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaLoopOperator.java x: 137 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMapPartitionsOperator.java x: 85 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReduceByOperator.java x: 131 lines of code y: 3 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSink.java x: 98 lines of code y: 3 # changes
35.0
# changes
  min: 1.0
  average: 5.22
  25th percentile: 3.0
  median: 5.0
  75th percentile: 7.0
  max: 35.0
0 721.0
lines of code
min: 1.0 | average: 64.89 | 25th percentile: 24.0 | median: 38.0 | 75th percentile: 79.0 | max: 721.0

Number of Contributors vs. Number of Changes: 1055 points

python/src/pywy/basic/data/__init__.py x: 2 # contributors y: 2 # changes python/src/pywy/basic/data/record.py x: 2 # contributors y: 4 # changes python/src/pywy/core/core.py x: 7 # contributors y: 15 # changes python/src/pywy/core/serializer.py x: 7 # contributors y: 19 # changes python/src/pywy/dataquanta.py x: 9 # contributors y: 22 # changes python/src/pywy/execution/util.py x: 5 # contributors y: 5 # changes python/src/pywy/execution/worker.py x: 5 # contributors y: 9 # changes python/src/pywy/graph/graph.py x: 5 # contributors y: 6 # changes python/src/pywy/operators/__init__.py x: 7 # contributors y: 14 # changes python/src/pywy/operators/base.py x: 9 # contributors y: 16 # changes python/src/pywy/operators/binary.py x: 7 # contributors y: 16 # changes python/src/pywy/operators/sink.py x: 7 # contributors y: 11 # changes python/src/pywy/operators/source.py x: 7 # contributors y: 12 # changes python/src/pywy/operators/unary.py x: 7 # contributors y: 17 # changes wayang-api/wayang-api-json/src/main/scala/Main.scala x: 6 # contributors y: 9 # changes wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 6 # contributors y: 26 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 6 # contributors y: 13 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 5 # contributors y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 6 # contributors y: 16 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedTransformationDescriptor.java x: 7 # contributors y: 8 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 13 # contributors y: 18 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 14 # contributors y: 22 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 4 # contributors y: 5 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 6 # contributors y: 7 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 15 # contributors y: 35 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 11 # contributors y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 # contributors y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 9 # contributors y: 11 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 13 # contributors y: 13 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 4 # contributors y: 4 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 16 # contributors y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 17 # contributors y: 21 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 8 # contributors y: 6 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 4 # contributors y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 15 # contributors y: 17 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 3 # contributors y: 5 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 # contributors y: 3 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/MultiConditionJoinFuncImpl.java x: 3 # contributors y: 2 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 11 # contributors y: 10 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 18 # contributors y: 21 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 10 # contributors y: 11 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 12 # contributors y: 16 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 11 # contributors y: 12 # changes wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 7 # contributors y: 9 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 13 # contributors y: 14 # changes wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 2 # contributors y: 5 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 5 # contributors y: 3 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 6 # contributors y: 6 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 6 # contributors y: 12 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 7 # contributors y: 5 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 9 # contributors y: 12 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/CollectionSplittableIterator.java x: 5 # contributors y: 4 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java x: 10 # contributors y: 13 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 9 # contributors y: 13 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 6 # contributors y: 11 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 11 # contributors y: 18 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 7 # contributors y: 10 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java x: 11 # contributors y: 15 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 6 # contributors y: 8 # changes wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 3 # contributors y: 4 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java x: 2 # contributors y: 6 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java x: 10 # contributors y: 14 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/TransformationDescriptor.java x: 9 # contributors y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java x: 4 # contributors y: 8 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/KafkaTopicSinkMapping.java x: 2 # contributors y: 3 # changes python/src/pywy/basic/model/ops.py x: 3 # contributors y: 6 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala x: 3 # contributors y: 8 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala x: 3 # contributors y: 7 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/FlatMapOperatorFromJson.scala x: 5 # contributors y: 10 # changes wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/MapOperatorFromJson.scala x: 5 # contributors y: 11 # changes wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/package.scala x: 9 # contributors y: 9 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala x: 8 # contributors y: 9 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java x: 12 # contributors y: 21 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java x: 6 # contributors y: 10 # changes wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java x: 8 # contributors y: 11 # changes wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java x: 5 # contributors y: 8 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java x: 8 # contributors y: 12 # changes wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkTextFileSource.java x: 8 # contributors y: 10 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java x: 7 # contributors y: 7 # changes wayang-benchmark/src/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala x: 8 # contributors y: 8 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java x: 14 # contributors y: 17 # changes wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/TypeConverter.java x: 6 # contributors y: 4 # changes wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java x: 7 # contributors y: 6 # changes wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java x: 1 # contributors y: 1 # changes wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcTableSource.java x: 2 # contributors y: 7 # changes wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java x: 2 # contributors y: 1 # changes wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/Sqlite3.java x: 1 # contributors y: 3 # changes
35.0
# changes
  min: 1.0
  average: 5.22
  25th percentile: 3.0
  median: 5.0
  75th percentile: 7.0
  max: 35.0
0 18.0
# contributors
min: 1.0 | average: 4.37 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 6.0 | max: 18.0

Number of Contributors vs. File Size: 1055 points

python/src/pywy/basic/data/__init__.py x: 2 # contributors y: 1 lines of code python/src/pywy/basic/data/record.py x: 2 # contributors y: 31 lines of code python/src/pywy/core/core.py x: 7 # contributors y: 56 lines of code python/src/pywy/core/serializer.py x: 7 # contributors y: 76 lines of code python/src/pywy/dataquanta.py x: 9 # contributors y: 154 lines of code python/src/pywy/execution/util.py x: 5 # contributors y: 7 lines of code python/src/pywy/execution/worker.py x: 5 # contributors y: 91 lines of code python/src/pywy/graph/graph.py x: 5 # contributors y: 58 lines of code python/src/pywy/operators/__init__.py x: 7 # contributors y: 27 lines of code python/src/pywy/operators/base.py x: 9 # contributors y: 66 lines of code python/src/pywy/operators/binary.py x: 7 # contributors y: 59 lines of code python/src/pywy/operators/sink.py x: 7 # contributors y: 24 lines of code python/src/pywy/operators/source.py x: 7 # contributors y: 44 lines of code python/src/pywy/operators/unary.py x: 7 # contributors y: 127 lines of code python/src/pywy/types.py x: 7 # contributors y: 154 lines of code wayang-api/wayang-api-json/src/main/scala/Main.scala x: 6 # contributors y: 49 lines of code wayang-api/wayang-api-json/src/main/scala/builder/JsonPlanBuilder.scala x: 6 # contributors y: 503 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflowConverter.scala x: 6 # contributors y: 83 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ContextFromJson.scala x: 5 # contributors y: 44 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/OperatorFromJson.scala x: 6 # contributors y: 135 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/PlanFromJson.scala x: 5 # contributors y: 37 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/IntersectOperatorFromJson.scala x: 6 # contributors y: 12 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/JoinOperatorFromJson.scala x: 6 # contributors y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/ParquetInputFromJson.scala x: 2 # contributors y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/unary/GroupByOperatorFromJson.scala x: 2 # contributors y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala x: 13 # contributors y: 61 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/PlanBuilder.scala x: 14 # contributors y: 73 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/NDimArray.scala x: 4 # contributors y: 30 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Record.java x: 6 # contributors y: 96 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuanta.scala x: 15 # contributors y: 610 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangAggregateVisitor.java x: 11 # contributors y: 60 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangCrossJoinVisitor.java x: 4 # contributors y: 33 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangFilterVisitor.java x: 9 # contributors y: 29 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangJoinVisitor.java x: 13 # contributors y: 52 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangMultiConditionJoinVisitor.java x: 4 # contributors y: 88 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangProjectVisitor.java x: 16 # contributors y: 25 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelConverter.java x: 17 # contributors y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangRelNodeVisitor.java x: 8 # contributors y: 10 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangSortVisitor.java x: 4 # contributors y: 48 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java x: 15 # contributors y: 50 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateAddCols.java x: 4 # contributors y: 38 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateFunction.java x: 4 # contributors y: 92 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/AggregateKeyExtractor.java x: 4 # contributors y: 19 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterEvaluateCondition.java x: 3 # contributors y: 116 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/FilterPredicateImpl.java x: 3 # contributors y: 14 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/JoinFlattenResult.java x: 3 # contributors y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/ProjectMapFuncImpl.java x: 4 # contributors y: 86 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortFilter.java x: 3 # contributors y: 18 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/functions/SortKeyExtractor.java x: 3 # contributors y: 30 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rel/WayangSort.java x: 3 # contributors y: 32 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java x: 11 # contributors y: 149 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/context/SqlContext.java x: 18 # contributors y: 79 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGoogleCloudStorageSource.java x: 5 # contributors y: 74 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaSortOperator.java x: 4 # contributors y: 60 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/execution/JdbcExecutor.java x: 10 # contributors y: 177 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala x: 12 # contributors y: 721 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java x: 11 # contributors y: 179 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/utils/ModelParser.java x: 7 # contributors y: 66 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/Main.java x: 13 # contributors y: 65 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCount.java x: 11 # contributors y: 38 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/wordcount/WordCountParquet.java x: 2 # contributors y: 52 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AmazonS3Source.java x: 5 # contributors y: 188 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/AzureBlobStorageSource.java x: 5 # contributors y: 185 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GoogleCloudStorageSource.java x: 6 # contributors y: 163 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java x: 6 # contributors y: 126 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ParquetSource.java x: 2 # contributors y: 125 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Operator.java x: 7 # contributors y: 270 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FunctionCompiler.java x: 9 # contributors y: 125 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorFunction.java x: 9 # contributors y: 23 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkExecutor.java x: 9 # contributors y: 107 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCartesianOperator.java x: 9 # contributors y: 73 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCoGroupOperator.java x: 9 # contributors y: 111 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSink.java x: 9 # contributors y: 75 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkCollectionSource.java x: 9 # contributors y: 100 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDistinctOperator.java x: 9 # contributors y: 63 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGlobalReduceOperator.java x: 9 # contributors y: 82 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkGroupByOperator.java x: 9 # contributors y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkJoinOperator.java x: 9 # contributors y: 103 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkLocalCallbackSink.java x: 9 # contributors y: 69 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSink.java x: 9 # contributors y: 78 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkObjectFileSource.java x: 9 # contributors y: 99 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkReduceByOperator.java x: 9 # contributors y: 87 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkRepeatExpandedOperator.java x: 9 # contributors y: 149 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkTextFileSink.java x: 9 # contributors y: 60 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/ScalaTupleSerializer.java x: 5 # contributors y: 33 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/platform/FlinkPlatform.java x: 10 # contributors y: 126 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/AmazonS3SourceMapping.java x: 5 # contributors y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/GoogleCloudStorageSourceMapping.java x: 4 # contributors y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/Mappings.java x: 9 # contributors y: 45 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ParquetSourceMapping.java x: 2 # contributors y: 32 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaAmazonS3Source.java x: 5 # contributors y: 70 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java x: 6 # contributors y: 98 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaParquetSource.java x: 2 # contributors y: 115 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTextFileSource.java x: 11 # contributors y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkParquetSource.java x: 2 # contributors y: 74 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/TensorflowModel.java x: 7 # contributors y: 130 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutor.java x: 7 # contributors y: 118 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/Mappings.java x: 11 # contributors y: 50 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkUnionAllOperator.java x: 6 # contributors y: 62 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/OutputSerializer.java x: 3 # contributors y: 9 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/Util.java x: 3 # contributors y: 7 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCount.java x: 3 # contributors y: 46 lines of code wayang-applications/src/main/java/org/apache/wayang/applications/WordCountOnKafkaTopic.java x: 3 # contributors y: 62 lines of code wayang-assembly/dependency-reduced-pom.xml x: 5 # contributors y: 162 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSource.java x: 3 # contributors y: 78 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/tpch/Query1.scala x: 5 # contributors y: 79 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/multicontext/apps/wordcount/WordCount.scala x: 5 # contributors y: 30 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/FlinkCoGroupFunction.java x: 6 # contributors y: 10 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/KeySelectorDistinct.java x: 6 # contributors y: 19 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/OutputFormatConsumer.java x: 6 # contributors y: 25 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/DummyFilter.java x: 6 # contributors y: 20 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangAggregator.java x: 6 # contributors y: 26 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangConvergenceCriterion.java x: 6 # contributors y: 33 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java x: 2 # contributors y: 177 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Configuration.java x: 10 # contributors y: 621 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/function/FunctionDescriptor.java x: 7 # contributors y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/ProbabilisticDoubleInterval.java x: 4 # contributors y: 78 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimator.java x: 4 # contributors y: 10 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadEstimate.java x: 5 # contributors y: 48 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfile.java x: 5 # contributors y: 120 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/InputSlot.java x: 4 # contributors y: 119 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorAlternative.java x: 4 # contributors y: 216 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorBase.java x: 4 # contributors y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainer.java x: 4 # contributors y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/OperatorContainers.java x: 4 # contributors y: 83 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/Slot.java x: 4 # contributors y: 54 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/SlotMapping.java x: 4 # contributors y: 185 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/UnarySink.java x: 4 # contributors y: 25 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/BasicDataUnitType.java x: 4 # contributors y: 41 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataSetType.java x: 4 # contributors y: 69 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/types/DataUnitType.java x: 4 # contributors y: 27 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaKafkaTopicSource.java x: 2 # contributors y: 79 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/KafkaTopicSourceMapping.java x: 2 # contributors y: 28 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkKafkaTopicSink.java x: 2 # contributors y: 83 lines of code python/src/pywy/basic/__init__.py x: 3 # contributors y: 1 lines of code python/src/pywy/basic/model/ops.py x: 3 # contributors y: 157 lines of code python/src/pywy/basic/model/option.py x: 3 # contributors y: 28 lines of code python/src/pywy/core/__init__.py x: 7 # contributors y: 7 lines of code wayang-api/wayang-api-json/src/main/scala/exception/WayangApiJsonException.scala x: 5 # contributors y: 2 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromdrawflow/OperatorFromDrawflow.scala x: 5 # contributors y: 14 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/ComposedOperatorFromJson.scala x: 5 # contributors y: 11 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/CoGroupOperatorFromJson.scala x: 5 # contributors y: 16 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/DLTrainingOperatorFromJson.scala x: 3 # contributors y: 68 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/binary/PredictOperatorFromJson.scala x: 3 # contributors y: 17 lines of code wayang-api/wayang-api-json/src/main/scala/operatorfromjson/input/TextFileInputFromJson.scala x: 5 # contributors y: 20 lines of code wayang-api/wayang-api-json/src/main/scala/parserutil/ParsePlanFromJson.scala x: 3 # contributors y: 25 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ProcessFeeder.java x: 5 # contributors y: 103 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/PythonWorkerManager.java x: 6 # contributors y: 31 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/executor/ReaderIterator.java x: 5 # contributors y: 53 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/function/WrappedPythonFunction.java x: 4 # contributors y: 16 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextDataQuanta.scala x: 4 # contributors y: 66 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/MultiContextPlanBuilder.scala x: 4 # contributors y: 76 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/DataQuantaAsyncResult.scala x: 4 # contributors y: 4 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/async/package.scala x: 4 # contributors y: 63 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/SerializationUtils.scala x: 4 # contributors y: 165 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/GenericSerializableDeserializer.scala x: 4 # contributors y: 12 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/OperatorDeserializer.scala x: 4 # contributors y: 286 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala x: 4 # contributors y: 22 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/IgnoreLoggerMixIn.scala x: 4 # contributors y: 7 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/OperatorMixIns.scala x: 4 # contributors y: 102 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/util/Parameters.scala x: 8 # contributors y: 70 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/WayangContext.java x: 12 # contributors y: 99 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimatorManager.java x: 6 # contributors y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/LoadProfileEstimators.java x: 6 # contributors y: 281 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/CrossPlatformExecutor.java x: 6 # contributors y: 604 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ReflectionUtils.java x: 6 # contributors y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkSampleOperator.java x: 8 # contributors y: 97 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRandomSampleOperator.java x: 5 # contributors y: 101 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReservoirSampleOperator.java x: 5 # contributors y: 90 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToRddOperator.java x: 6 # contributors y: 76 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/FunctionCompiler.java x: 8 # contributors y: 128 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/compiler/MapPartitionsFunctionAdapter.java x: 8 # contributors y: 24 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkBernoulliSampleOperator.java x: 8 # contributors y: 77 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkRandomPartitionSampleOperator.java x: 8 # contributors y: 207 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkShufflePartitionSampleOperator.java x: 8 # contributors y: 166 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectionSource.java x: 5 # contributors y: 177 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/DecisionTreeClassificationModel.java x: 7 # contributors y: 4 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Input.java x: 3 # contributors y: 37 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/model/op/Op.java x: 3 # contributors y: 51 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DLTrainingOperator.java x: 3 # contributors y: 59 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/DecisionTreeClassificationOperator.java x: 7 # contributors y: 15 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LinearRegressionOperator.java x: 7 # contributors y: 29 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ModelTransformOperator.java x: 7 # contributors y: 38 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/model/SparkMLModel.java x: 7 # contributors y: 11 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkLinearRegressionOperator.java x: 7 # contributors y: 124 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/ml/SparkModelTransformOperator.java x: 7 # contributors y: 62 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/channels/TensorChannel.java x: 3 # contributors y: 69 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/model/Convertor.java x: 3 # contributors y: 205 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowCollectOperator.java x: 3 # contributors y: 257 lines of code wayang-platforms/wayang-tensorflow/src/main/java/org/apache/wayang/tensorflow/operators/TensorflowDLTrainingOperator.java x: 3 # contributors y: 56 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/TPCHQ1WithJavaNative.java x: 3 # contributors y: 104 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/wordcount/WordCountScala.scala x: 8 # contributors y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainTreeNode.java x: 2 # contributors y: 58 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/ExplainUtils.java x: 2 # contributors y: 142 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/api/LocalStage.java x: 5 # contributors y: 5 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/ML4allPlan.java x: 5 # contributors y: 125 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/abstraction/plan/wrappers/AssignWrapper.java x: 5 # contributors y: 18 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/kmeans/KMeansUpdate.java x: 5 # contributors y: 27 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/algorithms/sgd/SGDLoop.java x: 5 # contributors y: 25 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/CardinalityRepository.java x: 5 # contributors y: 143 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonArray.java x: 4 # contributors y: 97 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/json/WayangJsonObj.java x: 4 # contributors y: 223 lines of code guides/pom-example.xml x: 6 # contributors y: 68 lines of code src/main/script/prerequisiteCheck.groovy x: 8 # contributors y: 143 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuanta.scala x: 7 # contributors y: 19 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/RecordDataQuantaBuilder.scala x: 7 # contributors y: 34 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderCache.scala x: 7 # contributors y: 14 lines of code wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/util/DataQuantaBuilderDecorator.scala x: 7 # contributors y: 49 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcSchema.java x: 5 # contributors y: 403 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/jdbc/JdbcUtils.java x: 5 # contributors y: 193 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java x: 8 # contributors y: 20 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/WayangTable.java x: 5 # contributors y: 40 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java x: 6 # contributors y: 124 lines of code wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java x: 6 # contributors y: 139 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/grep/Grep.java x: 5 # contributors y: 110 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/sgd/SGDImpl.java x: 7 # contributors y: 177 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/terasort/Random16.java x: 5 # contributors y: 294 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/LineItemTuple.java x: 7 # contributors y: 133 lines of code wayang-benchmark/src/main/java/org/apache/wayang/apps/tpch/data/q1/ReturnTuple.java x: 7 # contributors y: 52 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/benchmark/PlanGenerator.scala x: 7 # contributors y: 42 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/crocopr/CrocoPR.scala x: 7 # contributors y: 83 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/kmeans/postgres/Kmeans.scala x: 7 # contributors y: 122 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SelectNearestCentroidFunction.scala x: 8 # contributors y: 33 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/SimWords.scala x: 7 # contributors y: 116 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/simwords/Word2NVec.scala x: 7 # contributors y: 98 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/terasort/TeraGen.scala x: 5 # contributors y: 82 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/TpcH.scala x: 7 # contributors y: 90 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query1.scala x: 7 # contributors y: 92 lines of code wayang-benchmark/src/main/scala/org/apache/wayang/apps/tpch/queries/Query3Database.scala x: 7 # contributors y: 95 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KMeansOperator.java x: 8 # contributors y: 27 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/Job.java x: 14 # contributors y: 545 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/DefaultEstimatableCost.java x: 5 # contributors y: 244 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanImplementation.java x: 7 # contributors y: 665 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/fs/S3FileSystem.java x: 3 # contributors y: 194 lines of code wayang-ml4all/src/main/java/org/apache/wayang/ml4all/utils/SparseVector.java x: 5 # contributors y: 172 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/channels/DataSetChannel.java x: 6 # contributors y: 65 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/WayangFileOutputFormat.java x: 7 # contributors y: 282 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/compiler/criterion/WayangValue.java x: 6 # contributors y: 102 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/execution/FlinkContextReference.java x: 6 # contributors y: 56 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/DoWhileMapping.java x: 6 # contributors y: 37 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/FilterMapping.java x: 6 # contributors y: 36 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/mapping/SampleMapping.java x: 6 # contributors y: 41 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkDoWhileOperator.java x: 6 # contributors y: 155 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkIntersectOperator.java x: 6 # contributors y: 89 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkPageRankOperator.java x: 6 # contributors y: 167 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java x: 6 # contributors y: 70 lines of code wayang-platforms/wayang-flink/src/main/java/org/apache/wayang/flink/plugin/FlinkGraphPlugin.java x: 6 # contributors y: 6 lines of code wayang-platforms/wayang-generic-jdbc/src/main/java/org/apache/wayang/genericjdbc/execution/GenericJdbcExecutor.java x: 5 # contributors y: 153 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/channels/SqlQueryChannel.java x: 6 # contributors y: 72 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcJoinOperator.java x: 5 # contributors y: 54 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/SqlToStreamOperator.java x: 6 # contributors y: 159 lines of code wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/JoinMapping.java x: 5 # contributors y: 49 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/BroadcastChannel.java x: 6 # contributors y: 52 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/ChannelConversions.java x: 6 # contributors y: 87 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/FileChannels.java x: 6 # contributors y: 4 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/channels/RddChannel.java x: 6 # contributors y: 92 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/execution/SparkExecutionContext.java x: 6 # contributors y: 47 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/mapping/SampleMapping.java x: 6 # contributors y: 57 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/ApplicationEnd.java x: 5 # contributors y: 61 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/SparkListener.java x: 5 # contributors y: 375 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/StageCompleted.java x: 5 # contributors y: 113 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskEnd.java x: 5 # contributors y: 149 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/monitoring/metrics/TaskGettingResult.java x: 5 # contributors y: 147 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkDoWhileOperator.java x: 6 # contributors y: 131 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkFilterOperator.java x: 6 # contributors y: 77 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkGlobalMaterializedGroupOperator.java x: 6 # contributors y: 81 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkJoinOperator.java x: 6 # contributors y: 104 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkLoopOperator.java x: 6 # contributors y: 146 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/operators/SparkObjectFileSink.java x: 7 # contributors y: 72 lines of code wayang-platforms/wayang-spark/src/main/java/org/apache/wayang/spark/platform/SparkPlatform.java x: 7 # contributors y: 169 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/IEJoin.java x: 7 # contributors y: 82 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/mapping/spark/IESelfJoinMapping.java x: 7 # contributors y: 36 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIEJoinOperator.java x: 7 # contributors y: 107 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/JavaIESelfJoinOperator.java x: 7 # contributors y: 87 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/SparkIEJoinOperator.java x: 7 # contributors y: 158 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/BitSetJoin.java x: 7 # contributors y: 188 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/java_helpers/revDataComparator.java x: 7 # contributors y: 65 lines of code wayang-plugins/wayang-iejoin/src/main/java/org/apache/wayang/iejoin/operators/spark_helpers/BitSetJoin.java x: 7 # contributors y: 182 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfiler.java x: 7 # contributors y: 140 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/java/OperatorProfilers.java x: 6 # contributors y: 253 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizer.java x: 7 # contributors y: 201 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/GeneticOptimizerApp.java x: 7 # contributors y: 481 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/Individual.java x: 6 # contributors y: 172 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/LogEvaluator.java x: 7 # contributors y: 181 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/log/OptimizationSpace.java x: 6 # contributors y: 43 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/Main.java x: 7 # contributors y: 137 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/OperatorProfilers.java x: 6 # contributors y: 322 lines of code wayang-profiler/src/main/java/org/apache/wayang/profiler/spark/SparkOperatorProfiler.java x: 7 # contributors y: 262 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/platform/JdbcPlatformTemplate.java x: 2 # contributors y: 72 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSink.java x: 1 # contributors y: 26 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ObjectFileSource.java x: 1 # contributors y: 92 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSinkMapping.java x: 1 # contributors y: 35 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/ObjectFileSourceMapping.java x: 1 # contributors y: 40 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSink.java x: 3 # contributors y: 133 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaObjectFileSource.java x: 3 # contributors y: 164 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java x: 3 # contributors y: 153 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/SanityChecker.java x: 3 # contributors y: 93 lines of code wayang-docs/src/main/resources/_includes/head.html x: 2 # contributors y: 44 lines of code wayang-docs/src/main/resources/_layouts/default.html x: 2 # contributors y: 64 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/ProfileDB.java x: 2 # contributors y: 70 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Experiment.java x: 2 # contributors y: 90 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/Type.java x: 2 # contributors y: 10 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/model/measurement/TimeMeasurement.java x: 2 # contributors y: 102 lines of code wayang-commons/wayang-utils-profile-db/src/main/java/org/apache/wayang/commons/util/profiledb/storage/JDBCStorage.java x: 2 # contributors y: 47 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/costs/SimpleEstimationContext.java x: 4 # contributors y: 80 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecution.java x: 3 # contributors y: 101 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/AtomicExecutionGroup.java x: 3 # contributors y: 95 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PartialExecution.java x: 3 # contributors y: 134 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionLog.java x: 3 # contributors y: 90 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/graph/JavaPageRankOperator.java x: 2 # contributors y: 98 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/TextFileSource.java x: 2 # contributors y: 121 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumeration.java x: 2 # contributors y: 401 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/PlanEnumerator.java x: 2 # contributors y: 666 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/profiling/ExecutionPlanMeasurement.java x: 2 # contributors y: 169 lines of code wayang-docs/src/main/resources/_includes/sub-menu.html x: 2 # contributors y: 51 lines of code wayang-docs/src/main/resources/_sass/main.scss x: 2 # contributors y: 8 lines of code wayang-docs/src/main/resources/assets/css/main.css x: 2 # contributors y: 103 lines of code wayang-docs/src/main/resources/assets/css/monokai.css x: 2 # contributors y: 92 lines of code wayang-docs/src/main/resources/assets/js/add_numbers.js x: 2 # contributors y: 12 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/api/configuration/KeyValueProvider.java x: 2 # contributors y: 68 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/mapping/PlanTransformation.java x: 2 # contributors y: 110 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/OptimizationContext.java x: 2 # contributors y: 452 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/channels/ChannelConversionGraph.java x: 2 # contributors y: 629 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/ExecutionTaskFlowCompiler.java x: 2 # contributors y: 305 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/LatentOperatorPruningStrategy.java x: 2 # contributors y: 61 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/enumeration/StageAssignmentTraversal.java x: 2 # contributors y: 549 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/Channel.java x: 2 # contributors y: 249 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/ExecutionOperator.java x: 2 # contributors y: 148 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/LoopIsolator.java x: 2 # contributors y: 82 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/PlanTraversal.java x: 2 # contributors y: 180 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/wayangplan/WayangPlan.java x: 2 # contributors y: 111 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/ExecutorTemplate.java x: 2 # contributors y: 118 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/Junction.java x: 2 # contributors y: 135 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/lineage/LazyExecutionLineageNode.java x: 2 # contributors y: 94 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Algorithm/PageRankAlgorithm.java x: 2 # contributors y: 183 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/operators/GiraphPageRankOperator.java x: 2 # contributors y: 147 lines of code wayang-api/wayang-api-python/src/main/java/org/apache/wayang/api/python/PythonAPI.java x: 2 # contributors y: 5 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/channels/FileChannel.java x: 2 # contributors y: 139 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple2.java x: 2 # contributors y: 38 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/data/Tuple5.java x: 2 # contributors y: 56 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/function/ProjectionDescriptor.java x: 2 # contributors y: 107 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/MaterializedGroupByMapping.java x: 2 # contributors y: 41 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/mapping/PageRankMapping.java x: 2 # contributors y: 226 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/GlobalMaterializedGroupOperator.java x: 2 # contributors y: 25 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/LoopOperator.java x: 2 # contributors y: 194 lines of code wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/RepeatOperator.java x: 2 # contributors y: 130 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/CardinalityEstimationTraversal.java x: 2 # contributors y: 256 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/FixedSizeCardinalityEstimator.java x: 2 # contributors y: 18 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/optimizer/cardinality/OperatorAlternativeCardinalityPusher.java x: 2 # contributors y: 35 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionStage.java x: 2 # contributors y: 233 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/platform/PushExecutorTemplate.java x: 2 # contributors y: 222 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plugin/DynamicPlugin.java x: 2 # contributors y: 198 lines of code wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/util/Bitmask.java x: 2 # contributors y: 260 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/Sqlite3.java x: 1 # contributors y: 17 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/Mappings.java x: 1 # contributors y: 10 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/mapping/ProjectionMapping.java x: 1 # contributors y: 39 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3FilterOperator.java x: 1 # contributors y: 18 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/operators/Sqlite3ProjectionOperator.java x: 1 # contributors y: 21 lines of code wayang-platforms/wayang-sqlite3/src/main/java/org/apache/wayang/sqlite3/plugin/Sqlite3ConversionPlugin.java x: 1 # contributors y: 29 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcFilterOperator.java x: 1 # contributors y: 33 lines of code wayang-platforms/wayang-jdbc-template/src/main/java/org/apache/wayang/jdbc/operators/JdbcProjectionOperator.java x: 1 # contributors y: 49 lines of code wayang-platforms/wayang-postgres/src/main/java/org/apache/wayang/postgres/mapping/ProjectionMapping.java x: 1 # contributors y: 44 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/ChannelConversions.java x: 1 # contributors y: 59 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/JavaChannelInstance.java x: 1 # contributors y: 7 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/channels/StreamChannel.java x: 1 # contributors y: 71 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/SampleMapping.java x: 1 # contributors y: 53 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCartesianOperator.java x: 1 # contributors y: 123 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCoGroupOperator.java x: 1 # contributors y: 119 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaCountOperator.java x: 1 # contributors y: 63 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaDistinctOperator.java x: 1 # contributors y: 56 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFilterOperator.java x: 1 # contributors y: 76 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaFlatMapOperator.java x: 1 # contributors y: 86 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaGlobalMaterializedGroupOperator.java x: 1 # contributors y: 60 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaIntersectOperator.java x: 1 # contributors y: 99 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaJoinOperator.java x: 1 # contributors y: 139 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMapPartitionsOperator.java x: 1 # contributors y: 85 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaMaterializedGroupByOperator.java x: 1 # contributors y: 78 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaReduceByOperator.java x: 1 # contributors y: 131 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaRepeatOperator.java x: 1 # contributors y: 90 lines of code wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaTsvFileSource.java x: 1 # contributors y: 104 lines of code wayang-platforms/wayang-giraph/src/main/java/org/apache/wayang/giraph/Giraph.java x: 1 # contributors y: 12 lines of code
721.0
lines of code
  min: 1.0
  average: 64.89
  25th percentile: 24.0
  median: 38.0
  75th percentile: 79.0
  max: 721.0
0 18.0
# contributors
min: 1.0 | average: 4.37 | 25th percentile: 2.0 | median: 5.0 | 75th percentile: 6.0 | max: 18.0