apache / incubator-nemo
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 480 files with 32,605 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 3 files changed 21-50 times (959 lines of code)
    • 107 files changed 6-20 times (13,043 lines of code)
    • 370 files changed 1-5 times (18,603 lines of code)
0% | 0% | 2% | 40% | 57%
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 480 files with 32,605 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 1 file changed by 11-25 contributors (339 lines of code)
    • 40 files changed by 6-10 contributors (7,077 lines of code)
    • 330 files changed by 2-5 contributors (19,085 lines of code)
    • 109 files changed by 1 contributor (6,104 lines of code)
0% | 1% | 21% | 58% | 18%
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, xml, vue, js, sh, json, md, scala, py, txt, yml, gitignore, proto, editorconfig, properties, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 2% | 44% | 53%
proto0% | 0% | 87% | 12% | 0%
scala0% | 0% | 0% | 64% | 35%
vue0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
py0% | 0% | 0% | 0% | 100%
js0% | 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
compiler0% | 0% | 4% | 36% | 59%
client0% | 0% | 40% | 0% | 59%
runtime0% | 0% | 1% | 47% | 51%
common0% | 0% | 0% | 58% | 41%
conf0% | 0% | 0% | 76% | 23%
webui0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
ml0% | 0% | 0% | 0% | 100%
tools0% | 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
proto
ControlMessage.proto
in runtime/common/src/main/proto
 222 - 2017-11-29 2019-03-30 29 10 jeongyoon0807@gmail.com wonook@apache.org
JobLauncher.java
in client/src/main/java/org/apache/nemo/client
 339 20 2018-09-06 2021-10-18 23 15 jangho@jangho.io goehd4551@gmail.com
PipelineTranslator.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 398 14 2018-09-06 2022-08-01 23 10 jangho@jangho.io wsong0512@gmail.com
TaskExecutor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 533 20 2018-09-06 2022-08-01 20 10 jangho@jangho.io wsong0512@gmail.com
BatchScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 234 13 2018-09-06 2020-11-24 16 8 jangho@jangho.io 43122460+polarcoke2@users.n...
IRDAG.java
in common/src/main/java/org/apache/nemo/common/ir
 644 48 2019-02-01 2020-11-19 16 10 johnyangk@gmail.com 60352009+jaehwan0214@users....
SkewReshapingPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 47 2 2018-09-06 2020-07-03 14 10 jangho@jangho.io 43122460+polarcoke2@users.n...
JobConf.java
in conf/src/main/java/org/apache/nemo/conf
 161 - 2018-09-06 2021-10-18 14 8 jangho@jangho.io goehd4551@gmail.com
LoopVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 245 32 2018-09-06 2020-12-11 14 8 jangho@jangho.io wsong0512@gmail.com
RuntimeMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 346 14 2018-09-06 2021-04-02 14 7 jangho@jangho.io goehd4551@naver.com
Util.java
in common/src/main/java/org/apache/nemo/common
 171 15 2019-01-14 2022-08-01 13 8 2631737+arunlakshman@users.... wsong0512@gmail.com
AbstractDoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 189 14 2018-10-19 2022-08-01 13 8 taegeonum@gmail.com wsong0512@gmail.com
SourceVertexDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 83 6 2018-09-06 2022-08-02 12 7 jangho@jangho.io wsong0512@gmail.com
PipeOutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 108 8 2018-10-30 2022-08-01 12 7 johnyangk@gmail.com wsong0512@gmail.com
BlockManagerWorker.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 366 10 2018-09-06 2020-11-19 12 9 jangho@jangho.io 60352009+jaehwan0214@users....
DoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 56 6 2018-10-11 2020-12-11 11 6 taegeonum@gmail.com wsong0512@gmail.com
CreateViewTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 81 8 2018-09-06 2021-10-18 11 6 jangho@jangho.io goehd4551@gmail.com
BeamBoundedSourceVertex.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source
 135 13 2018-09-06 2019-03-27 11 4 jangho@jangho.io wonook@apache.org
BytesDecoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 50 5 2018-09-06 2019-12-17 10 6 jangho@jangho.io 48579185+ulgal@users.norepl...
UserApplicationRunner.java
in runtime/driver/src/main/java/org/apache/nemo/driver
 71 2 2018-09-06 2020-11-24 10 5 jangho@jangho.io 43122460+polarcoke2@users.n...
BeamUnboundedSourceVertex.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source
 123 13 2018-10-25 2019-03-27 10 6 strayyyyyy@gmail.com wonook@apache.org
MultiThreadParentTaskDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 158 11 2018-11-01 2022-08-01 10 9 johnyangk@gmail.com wsong0512@gmail.com
DAGBuilder.java
in common/src/main/java/org/apache/nemo/common/dag
 269 22 2018-09-06 2020-12-11 10 6 jangho@jangho.io wsong0512@gmail.com
PlanStateManager.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 396 26 2018-09-06 2021-08-16 10 5 jangho@jangho.io wsong0512@gmail.com
BlockOutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 100 6 2018-10-30 2022-08-01 9 6 johnyangk@gmail.com wsong0512@gmail.com
OperatorVertexOutputCollector.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 102 7 2018-10-28 2022-08-01 9 5 taegeonum@gmail.com wsong0512@gmail.com
SerializedPartition.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition
 138 11 2018-09-06 2019-10-23 9 5 jangho@jangho.io chohy0555@gmail.com
ParentTaskDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 158 9 2018-09-06 2021-10-18 9 5 jangho@jangho.io goehd4551@gmail.com
Executor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor
 185 10 2018-09-06 2021-10-18 9 7 jangho@jangho.io goehd4551@gmail.com
PhysicalPlanGenerator.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan
 196 7 2018-09-06 2019-10-22 9 4 jangho@jangho.io jangho@jangho.io
MetricStore.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric
 229 16 2019-02-15 2021-04-02 9 3 wonook@apache.org goehd4551@naver.com
DataUtil.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 296 18 2018-09-06 2021-10-18 9 5 jangho@jangho.io goehd4551@gmail.com
OutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 11 - 2018-09-06 2022-08-01 8 7 jangho@jangho.io wsong0512@gmail.com
BytesEncoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 29 6 2018-09-06 2020-01-19 8 6 jangho@jangho.io yunsoo3042@gmail.com
DataFetcherOutputCollector.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 36 5 2018-10-28 2022-08-01 8 4 taegeonum@gmail.com wsong0512@gmail.com
GroupByKeyTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 40 4 2018-09-06 2019-03-27 8 4 jangho@jangho.io wonook@apache.org
IRVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 50 9 2018-09-06 2019-03-30 8 4 jangho@jangho.io wonook@apache.org
SparkFrontendUtils.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core
 118 7 2018-09-06 2020-02-10 8 6 jangho@jangho.io jeongyoon0807@gmail.com
ExecutionPropertyMap.java
in common/src/main/java/org/apache/nemo/common/ir/executionproperty
 126 15 2018-09-06 2019-09-09 8 5 jangho@jangho.io wsong0512@gmail.com
PolicyImpl.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy
 128 6 2018-09-06 2020-02-06 8 5 jangho@jangho.io xiangmu97@naver.com
DefaultScheduleGroupPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
 138 7 2018-09-06 2020-01-28 8 5 jangho@jangho.io wsong0512@gmail.com
NemoOptimizer.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer
 150 6 2018-09-06 2020-03-09 8 5 jangho@jangho.io wsong0512@gmail.com
ResourceSitePass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
 182 11 2018-09-06 2019-10-22 8 6 jangho@jangho.io jangho@jangho.io
PipelineTranslationContext.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 188 12 2018-11-06 2020-10-18 8 5 johnyangk@gmail.com 60352009+jaehwan0214@users....
TaskMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 239 41 2018-09-06 2022-08-01 8 6 jangho@jangho.io wsong0512@gmail.com
DAG.java
in common/src/main/java/org/apache/nemo/common/dag
 247 28 2018-09-06 2020-01-07 8 4 jangho@jangho.io kdh9949@snu.ac.kr
FileBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
 248 11 2018-09-06 2020-02-11 8 6 jangho@jangho.io jeongyoon0807@gmail.com
MetricUtils.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 306 15 2019-02-15 2019-12-06 8 3 wonook@apache.org bdv111@snu.ac.kr
IRDAGChecker.java
in common/src/main/java/org/apache/nemo/common/ir
 442 22 2019-03-06 2020-11-24 8 6 johnyangk@gmail.com 43122460+polarcoke2@users.n...
OutputCollector.java
in common/src/main/java/org/apache/nemo/common/ir
 10 - 2018-09-06 2022-08-01 7 6 jangho@jangho.io wsong0512@gmail.com
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
JobLauncher.java
in client/src/main/java/org/apache/nemo/client
 339 20 2018-09-06 2021-10-18 23 15 jangho@jangho.io goehd4551@gmail.com
proto
ControlMessage.proto
in runtime/common/src/main/proto
 222 - 2017-11-29 2019-03-30 29 10 jeongyoon0807@gmail.com wonook@apache.org
PipelineTranslator.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 398 14 2018-09-06 2022-08-01 23 10 jangho@jangho.io wsong0512@gmail.com
TaskExecutor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 533 20 2018-09-06 2022-08-01 20 10 jangho@jangho.io wsong0512@gmail.com
IRDAG.java
in common/src/main/java/org/apache/nemo/common/ir
 644 48 2019-02-01 2020-11-19 16 10 johnyangk@gmail.com 60352009+jaehwan0214@users....
SkewReshapingPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 47 2 2018-09-06 2020-07-03 14 10 jangho@jangho.io 43122460+polarcoke2@users.n...
BlockManagerWorker.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 366 10 2018-09-06 2020-11-19 12 9 jangho@jangho.io 60352009+jaehwan0214@users....
MultiThreadParentTaskDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 158 11 2018-11-01 2022-08-01 10 9 johnyangk@gmail.com wsong0512@gmail.com
BatchScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 234 13 2018-09-06 2020-11-24 16 8 jangho@jangho.io 43122460+polarcoke2@users.n...
LoopVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 245 32 2018-09-06 2020-12-11 14 8 jangho@jangho.io wsong0512@gmail.com
JobConf.java
in conf/src/main/java/org/apache/nemo/conf
 161 - 2018-09-06 2021-10-18 14 8 jangho@jangho.io goehd4551@gmail.com
Util.java
in common/src/main/java/org/apache/nemo/common
 171 15 2019-01-14 2022-08-01 13 8 2631737+arunlakshman@users.... wsong0512@gmail.com
AbstractDoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 189 14 2018-10-19 2022-08-01 13 8 taegeonum@gmail.com wsong0512@gmail.com
RuntimeMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 346 14 2018-09-06 2021-04-02 14 7 jangho@jangho.io goehd4551@naver.com
PipeOutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 108 8 2018-10-30 2022-08-01 12 7 johnyangk@gmail.com wsong0512@gmail.com
SourceVertexDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 83 6 2018-09-06 2022-08-02 12 7 jangho@jangho.io wsong0512@gmail.com
Executor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor
 185 10 2018-09-06 2021-10-18 9 7 jangho@jangho.io goehd4551@gmail.com
OutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 11 - 2018-09-06 2022-08-01 8 7 jangho@jangho.io wsong0512@gmail.com
SamplingSkewReshapingPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 85 3 2019-02-21 2020-07-03 7 7 johnyangk@gmail.com 43122460+polarcoke2@users.n...
DoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 56 6 2018-10-11 2020-12-11 11 6 taegeonum@gmail.com wsong0512@gmail.com
CreateViewTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 81 8 2018-09-06 2021-10-18 11 6 jangho@jangho.io goehd4551@gmail.com
DAGBuilder.java
in common/src/main/java/org/apache/nemo/common/dag
 269 22 2018-09-06 2020-12-11 10 6 jangho@jangho.io wsong0512@gmail.com
BytesDecoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 50 5 2018-09-06 2019-12-17 10 6 jangho@jangho.io 48579185+ulgal@users.norepl...
BeamUnboundedSourceVertex.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source
 123 13 2018-10-25 2019-03-27 10 6 strayyyyyy@gmail.com wonook@apache.org
BlockOutputWriter.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 100 6 2018-10-30 2022-08-01 9 6 johnyangk@gmail.com wsong0512@gmail.com
TaskMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 239 41 2018-09-06 2022-08-01 8 6 jangho@jangho.io wsong0512@gmail.com
FileBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
 248 11 2018-09-06 2020-02-11 8 6 jangho@jangho.io jeongyoon0807@gmail.com
IRDAGChecker.java
in common/src/main/java/org/apache/nemo/common/ir
 442 22 2019-03-06 2020-11-24 8 6 johnyangk@gmail.com 43122460+polarcoke2@users.n...
BytesEncoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 29 6 2018-09-06 2020-01-19 8 6 jangho@jangho.io yunsoo3042@gmail.com
SparkFrontendUtils.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core
 118 7 2018-09-06 2020-02-10 8 6 jangho@jangho.io jeongyoon0807@gmail.com
ResourceSitePass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
 182 11 2018-09-06 2019-10-22 8 6 jangho@jangho.io jangho@jangho.io
ContainerManager.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/resource
 161 7 2018-09-06 2020-03-09 7 6 jangho@jangho.io wsong0512@gmail.com
BlockInputReader.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 142 6 2018-10-30 2020-03-07 7 6 johnyangk@gmail.com 43122460+polarcoke2@users.n...
Transform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
 18 - 2018-09-06 2022-08-01 7 6 jangho@jangho.io wsong0512@gmail.com
OutputCollector.java
in common/src/main/java/org/apache/nemo/common/ir
 10 - 2018-09-06 2022-08-01 7 6 jangho@jangho.io wsong0512@gmail.com
WindowFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 61 5 2018-10-11 2021-10-18 7 6 taegeonum@gmail.com goehd4551@gmail.com
PushBackDoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 103 7 2018-11-21 2020-12-11 7 6 johnyangk@gmail.com wsong0512@gmail.com
ReduceTransform.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform
 56 6 2018-09-06 2021-10-18 7 6 jangho@jangho.io goehd4551@gmail.com
LoopOptimizations.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 214 10 2018-09-06 2020-01-13 7 6 jangho@jangho.io 43871098+byungheecha@users....
PipeManagerWorker.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 135 8 2018-10-30 2020-11-19 6 6 johnyangk@gmail.com 60352009+jaehwan0214@users....
SkewHandlingUtil.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 54 3 2019-02-21 2020-07-03 6 6 johnyangk@gmail.com 43122460+polarcoke2@users.n...
UserApplicationRunner.java
in runtime/driver/src/main/java/org/apache/nemo/driver
 71 2 2018-09-06 2020-11-24 10 5 jangho@jangho.io 43122460+polarcoke2@users.n...
PlanStateManager.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 396 26 2018-09-06 2021-08-16 10 5 jangho@jangho.io wsong0512@gmail.com
OperatorVertexOutputCollector.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 102 7 2018-10-28 2022-08-01 9 5 taegeonum@gmail.com wsong0512@gmail.com
ParentTaskDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 158 9 2018-09-06 2021-10-18 9 5 jangho@jangho.io goehd4551@gmail.com
DataUtil.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 296 18 2018-09-06 2021-10-18 9 5 jangho@jangho.io goehd4551@gmail.com
SerializedPartition.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition
 138 11 2018-09-06 2019-10-23 9 5 jangho@jangho.io chohy0555@gmail.com
ExecutionPropertyMap.java
in common/src/main/java/org/apache/nemo/common/ir/executionproperty
 126 15 2018-09-06 2019-09-09 8 5 jangho@jangho.io wsong0512@gmail.com
PipelineTranslationContext.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 188 12 2018-11-06 2020-10-18 8 5 johnyangk@gmail.com 60352009+jaehwan0214@users....
NemoOptimizer.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer
 150 6 2018-09-06 2020-03-09 8 5 jangho@jangho.io wsong0512@gmail.com
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
DAG.vue
in webui/components/jobs/detail
 662 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
SparkJavaPairRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 511 65 2020-02-11 2020-02-11 1 1 jeongyoon0807@gmail.com jeongyoon0807@gmail.com
SparkJavaRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 423 76 2020-02-11 2020-02-11 1 1 jeongyoon0807@gmail.com jeongyoon0807@gmail.com
SimulationScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 397 29 2020-03-09 2020-03-09 1 1 wsong0512@gmail.com wsong0512@gmail.com
TaskSizeSplitterVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility
 321 17 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
264 23 2019-03-30 2019-03-30 1 1 wonook@apache.org wonook@apache.org
PairRDDFunctions.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
 222 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
ByteInputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 181 11 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
StageSelect.vue
in webui/components/jobs/detail
 172 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
StagesView.vue
in webui/components/stages
 142 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
ByteTransferContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 128 17 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
MetricTimeline.vue
in webui/components/jobs/detail
 126 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
ClientRPC.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message
 110 9 2019-03-30 2019-03-30 1 1 wonook@apache.org wonook@apache.org
DynamicTaskSizingRuntimePass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime
 100 5 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
DirectByteBufferOutputStream.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 99 8 2019-08-07 2019-10-23 2 1 chohy0555@gmail.com chohy0555@gmail.com
ParallelismProphet.java
in compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet
 93 5 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
DataFrameEncoder.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 87 7 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
PlanAppender.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 80 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
network_profiling.py
in tools/network_profiling
 79 2 2021-08-16 2021-08-16 1 1 wsong0512@gmail.com wsong0512@gmail.com
ByteTransfer.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 72 5 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
MessageUtils.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message
 71 1 2020-03-09 2020-03-09 1 1 wsong0512@gmail.com wsong0512@gmail.com
ClosableBlockingQueue.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 56 7 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
LatencyMark.java
in common/src/main/java/org/apache/nemo/common/punctuation
 54 10 2022-08-01 2022-08-01 1 1 wsong0512@gmail.com wsong0512@gmail.com
MetricManagerMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric
 52 4 2019-02-15 2019-03-27 2 1 wonook@apache.org wonook@apache.org
MetricBroadcaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric
 49 6 2019-02-15 2019-03-27 2 1 wonook@apache.org wonook@apache.org
LocalOutputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 49 7 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
DetailTable.vue
in webui/components/jobs/detail
 49 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
ResourceSpecification.java
in common/src/main/java/org/apache/nemo/common/ir/executionproperty
 47 8 2020-03-09 2020-03-09 1 1 wsong0512@gmail.com wsong0512@gmail.com
ByteTransportChannelInitializer.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 44 2 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
TransientResourceDataTransferPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
 43 5 2019-09-24 2019-09-24 1 1 johnyangk@apache.org johnyangk@apache.org
OptimizerUtils.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer
 43 3 2019-03-30 2019-03-30 1 1 wonook@apache.org wonook@apache.org
MessageGeneratorTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
 41 5 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
39 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
FinalCombineFn.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 39 6 2020-10-14 2020-10-14 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
PartialCombineFn.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 38 6 2020-10-14 2020-10-14 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
SparkSourceUtil.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source
 38 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
PhysicalPlan.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan
 35 5 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
StreamMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 35 6 2021-10-18 2021-10-18 1 1 goehd4551@gmail.com goehd4551@gmail.com
DynamicTaskSizingPolicy.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy
 34 3 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
ExecutorsView.vue
in webui/components/executors
 32 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
EnvironmentView.vue
in webui/components/environment
 32 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
RemoteClientMessageLoggingHandler.java
in runtime/driver/src/main/java/org/apache/nemo/driver
 31 4 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
StageMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 31 5 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
LocalTransferContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 31 4 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
StorageView.vue
in webui/components/storage
 31 - 2018-12-15 2018-12-15 1 1 wonook@apache.org wonook@apache.org
SignalTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
 29 4 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
DecoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 28 3 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
EncoderFactory.java
in common/src/main/java/org/apache/nemo/common/coder
 28 3 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
NioChannelImplementationSelector.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common
 26 4 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
WatermarkWithIndex.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
 25 4 2018-11-13 2018-11-13 1 1 taegeonum@gmail.com taegeonum@gmail.com
Correlations

File Size vs. Number of Changes: 481 points

common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java x: 17 lines of code y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java x: 28 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java x: 140 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeContainer.java x: 91 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDataFetcher.java x: 83 lines of code y: 12 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteOutputContext.java x: 151 lines of code y: 2 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java x: 185 lines of code y: 2 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ContextManager.java x: 160 lines of code y: 2 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ControlFrameEncoder.java x: 48 lines of code y: 2 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/PipeTransferForAllEdgesPass.java x: 21 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricManagerWorker.java x: 77 lines of code y: 6 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/StreamingScheduler.java x: 120 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java x: 10 lines of code y: 7 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.java x: 11 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/Transform.java x: 18 lines of code y: 7 # changes common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java x: 54 lines of code y: 1 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.java x: 189 lines of code y: 13 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.java x: 212 lines of code y: 5 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/LatencyMetric.java x: 22 lines of code y: 2 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java x: 239 lines of code y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockOutputWriter.java x: 100 lines of code y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/DataFetcherOutputCollector.java x: 36 lines of code y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventDecoderFactory.java x: 61 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventEncoderFactory.java x: 48 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java x: 102 lines of code y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorWatermarkCollector.java x: 30 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OutputWriter.java x: 11 lines of code y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeOutputWriter.java x: 108 lines of code y: 12 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/RunTimeMessageOutputCollector.java x: 77 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadParentTaskDataFetcher.java x: 158 lines of code y: 10 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java x: 533 lines of code y: 20 # changes common/src/main/java/org/apache/nemo/common/Util.java x: 171 lines of code y: 13 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java x: 398 lines of code y: 23 # changes client/src/main/java/org/apache/nemo/client/JobLauncher.java x: 339 lines of code y: 23 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.java x: 81 lines of code y: 11 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java x: 25 lines of code y: 7 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java x: 33 lines of code y: 4 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.java x: 61 lines of code y: 7 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/FlatMapTransform.java x: 25 lines of code y: 6 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapToPairTransform.java x: 27 lines of code y: 6 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceTransform.java x: 56 lines of code y: 7 # changes conf/src/main/java/org/apache/nemo/conf/JobConf.java x: 161 lines of code y: 14 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StreamMetric.java x: 35 lines of code y: 1 # changes runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java x: 207 lines of code y: 7 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java x: 185 lines of code y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DataUtil.java x: 296 lines of code y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/ParentTaskDataFetcher.java x: 158 lines of code y: 9 # changes tools/network_profiling/network_clustering.py x: 22 lines of code y: 1 # changes tools/network_profiling/network_profiling.py x: 79 lines of code y: 1 # changes client/src/main/java/org/apache/nemo/client/ClientUtils.java x: 56 lines of code y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java x: 396 lines of code y: 10 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java x: 346 lines of code y: 14 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java x: 229 lines of code y: 9 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ExecutorRegistry.java x: 84 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java x: 269 lines of code y: 10 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/SubPartitionSetProperty.java x: 12 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java x: 245 lines of code y: 14 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.java x: 56 lines of code y: 11 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryTimerInternalsFactory.java x: 49 lines of code y: 2 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.java x: 103 lines of code y: 7 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPass.java x: 195 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalInputContext.java x: 56 lines of code y: 2 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/TransferOutputStream.java x: 7 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/exception/RuntimeOptimizationException.java x: 9 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java x: 442 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/ir/IdManager.java x: 50 lines of code y: 7 # changes compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java x: 114 lines of code y: 6 # changes compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/ParallelismProphet.java x: 93 lines of code y: 1 # changes compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/Prophet.java x: 5 lines of code y: 1 # changes compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/SkewProphet.java x: 25 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/DynamicTaskSizingRuntimePass.java x: 100 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DynamicTaskSizingPolicy.java x: 34 lines of code y: 1 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PlanRewriter.java x: 6 lines of code y: 3 # changes runtime/driver/src/main/java/org/apache/nemo/driver/UserApplicationRunner.java x: 71 lines of code y: 10 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java x: 234 lines of code y: 16 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchSchedulerUtils.java x: 238 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulatedTaskExecutor.java x: 147 lines of code y: 2 # changes client/src/main/java/org/apache/reef/runtime/yarn/ClassPathBuilder.java x: 46 lines of code y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/IRDAG.java x: 644 lines of code y: 16 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java x: 366 lines of code y: 12 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssigner.java x: 84 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java x: 135 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteInputContext.java x: 181 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransfer.java x: 72 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransferContext.java x: 128 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransportChannelInitializer.java x: 44 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ClosableBlockingQueue.java x: 56 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/DataFrameEncoder.java x: 87 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalOutputContext.java x: 49 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalTransferContext.java x: 31 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/OutputContext.java x: 6 lines of code y: 1 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/package-info.java x: 1 lines of code y: 1 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslationContext.java x: 188 lines of code y: 8 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.java x: 39 lines of code y: 1 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryStateInternalsFactory.java x: 23 lines of code y: 1 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.java x: 38 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.java x: 39 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.java x: 41 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/SignalTransform.java x: 29 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/utility/SamplingVertex.java x: 67 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java x: 321 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.java x: 18 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/SignalVertex.java x: 13 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingSkewReshapingPass.java x: 85 lines of code y: 7 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewHandlingUtil.java x: 54 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewReshapingPass.java x: 47 lines of code y: 14 # changes client/src/main/java/org/apache/nemo/client/ClientEndpoint.java x: 76 lines of code y: 4 # changes client/src/main/java/org/apache/nemo/client/DriverEndpoint.java x: 24 lines of code y: 4 # changes client/src/main/java/org/apache/nemo/client/beam/NemoPipelineResult.java x: 65 lines of code y: 3 # changes client/src/main/java/org/apache/nemo/client/beam/NemoRunner.java x: 37 lines of code y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/executionproperty/ResourceSpecification.java x: 47 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/NemoOptimizer.java x: 150 lines of code y: 8 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java x: 59 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/JobMetric.java x: 108 lines of code y: 7 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Task.java x: 81 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TaskStateManager.java x: 86 lines of code y: 6 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ContainerManager.java x: 161 lines of code y: 7 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/DefaultExecutorRepresenter.java x: 158 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java x: 397 lines of code y: 1 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java x: 155 lines of code y: 6 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/EnableDynamicTaskSizingProperty.java x: 10 lines of code y: 1 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Stage.java x: 83 lines of code y: 7 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java x: 100 lines of code y: 7 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockInputReader.java x: 142 lines of code y: 7 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/IntermediateDataIOFactory.java x: 46 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeInputReader.java x: 65 lines of code y: 5 # changes webui/components/MainContainer.vue x: 91 lines of code y: 3 # changes webui/components/jobs/JobsView.vue x: 726 lines of code y: 2 # changes webui/components/jobs/detail/JobView.vue x: 272 lines of code y: 2 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkEncoderFactory.java x: 34 lines of code y: 5 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/JavaSparkContext.java x: 22 lines of code y: 4 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkContext.java x: 35 lines of code y: 4 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaPairRDD.java x: 511 lines of code y: 1 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaRDD.java x: 423 lines of code y: 1 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/Dataset.java x: 656 lines of code y: 4 # changes compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala x: 397 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LambdaPass.java x: 15 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/FileBlock.java x: 248 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/coder/LongEncoderFactory.java x: 30 lines of code y: 6 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkFrontendUtils.java x: 118 lines of code y: 8 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyImpl.java x: 128 lines of code y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/DataFetcher.java x: 20 lines of code y: 7 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageClient.java x: 80 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryChunk.java x: 272 lines of code y: 4 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java x: 138 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/StateMachine.java x: 169 lines of code y: 6 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/LocalTextFileTransform.java x: 38 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/FileMetadata.java x: 43 lines of code y: 4 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LargeShuffleReshapingPass.java x: 23 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/Block.java x: 18 lines of code y: 4 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageSender.java x: 7 lines of code y: 4 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.java x: 60 lines of code y: 4 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageServer.java x: 106 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/coder/BytesEncoderFactory.java x: 29 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/InMemorySourceVertex.java x: 76 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/GlusterFileStore.java x: 85 lines of code y: 6 # changes conf/src/main/java/org/apache/nemo/conf/DataPlaneConf.java x: 49 lines of code y: 3 # changes runtime/driver/src/main/java/org/apache/nemo/driver/NemoContext.java x: 56 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/Readable.java x: 12 lines of code y: 7 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.java x: 74 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java x: 214 lines of code y: 7 # changes common/src/main/java/org/apache/nemo/common/dag/DAG.java x: 247 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/dag/DAGInterface.java x: 42 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/pass/Pass.java x: 19 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalFileStore.java x: 60 lines of code y: 6 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/SparkSession.java x: 242 lines of code y: 5 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/CollectTransform.java x: 26 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/Pair.java x: 36 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java x: 50 lines of code y: 10 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemorySideInputReader.java x: 61 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/SerializedMemoryBlock.java x: 144 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java x: 135 lines of code y: 4 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceByKeyTransform.java x: 44 lines of code y: 5 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java x: 306 lines of code y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/SerializedMemoryStore.java x: 39 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DirectByteBufferOutputStream.java x: 99 lines of code y: 2 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/SerializedPartition.java x: 138 lines of code y: 9 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java x: 182 lines of code y: 8 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java x: 196 lines of code y: 9 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java x: 190 lines of code y: 6 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StagePartitioner.java x: 63 lines of code y: 7 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/PipeManagerMaster.java x: 111 lines of code y: 3 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/XGBoostPass.java x: 88 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/BlockFetchFailureProperty.java x: 14 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourceDataTransferPass.java x: 43 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/TransientResourceCompositePass.java x: 12 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputReader.java x: 18 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java x: 23 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/coder/PairDecoderFactory.java x: 49 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/coder/PairEncoderFactory.java x: 51 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CommunicationPatternProperty.java x: 16 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataFlowProperty.java x: 14 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.java x: 17 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.java x: 126 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLambdaProperty.java x: 14 lines of code y: 2 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/BeamKeyExtractor.java x: 28 lines of code y: 7 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java x: 25 lines of code y: 4 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultDataPersistencePass.java x: 29 lines of code y: 5 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LargeShuffleAnnotatingPass.java x: 32 lines of code y: 7 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java x: 129 lines of code y: 5 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/LocalitySchedulingConstraint.java x: 89 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ByteBufferInputStream.java x: 28 lines of code y: 2 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/Policy.java x: 8 lines of code y: 6 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ExecutorRepresenter.java x: 19 lines of code y: 7 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/NonSerializedMemoryBlock.java x: 121 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalBlockStore.java x: 23 lines of code y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/AntiAffinitySchedulingConstraint.java x: 34 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/NodeShareSchedulingConstraint.java x: 45 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/exception/IllegalEdgeOperationException.java x: 9 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/IRVertex.java x: 50 lines of code y: 8 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLocalityProperty.java x: 12 lines of code y: 3 # changes ml/nemo_xgboost_optimization.py x: 264 lines of code y: 1 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ClientRPC.java x: 110 lines of code y: 1 # changes runtime/common/src/main/proto/ControlMessage.proto x: 222 lines of code y: 29 # changes client/src/main/java/org/apache/nemo/client/StateTranslator.java x: 5 lines of code y: 3 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/Optimizer.java x: 9 lines of code y: 5 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StateMetric.java x: 7 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricMessageSender.java x: 8 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/RemoteFileMetadata.java x: 70 lines of code y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricMessageHandler.java x: 8 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraint.java x: 11 lines of code y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingPolicy.java x: 14 lines of code y: 3 # changes client/src/main/java/org/apache/nemo/client/DriverRPCServer.java x: 120 lines of code y: 3 # changes client/src/main/java/org/apache/nemo/client/beam/NemoRunnerRegistrar.java x: 26 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/HashRange.java x: 62 lines of code y: 6 # changes common/src/main/java/org/apache/nemo/common/dag/Vertex.java x: 20 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/eventhandler/CommonEventHandler.java x: 5 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/eventhandler/CompilerEventHandler.java x: 3 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/ir/BoundedIteratorReadable.java x: 18 lines of code y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java x: 69 lines of code y: 6 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupProperty.java x: 10 lines of code y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java x: 66 lines of code y: 6 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/SourceVertex.java x: 15 lines of code y: 7 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/MessageIdVertexProperty.java x: 10 lines of code y: 2 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ParallelismProperty.java x: 10 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/partitioner/HashPartitioner.java x: 15 lines of code y: 2 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.java x: 37 lines of code y: 4 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.java x: 135 lines of code y: 11 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.java x: 123 lines of code y: 10 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.java x: 58 lines of code y: 3 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GroupByKeyTransform.java x: 40 lines of code y: 8 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkTextFileBoundedSourceVertex.java x: 100 lines of code y: 5 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/DataFrameReader.java x: 271 lines of code y: 3 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/NemoSparkUserFacingClass.java x: 20 lines of code y: 3 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/AnnotatingPass.java x: 25 lines of code y: 3 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/CompositePass.java x: 40 lines of code y: 5 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java x: 209 lines of code y: 5 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/ReshapingPass.java x: 18 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/RunTimePass.java x: 6 lines of code y: 2 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/ConditionalLargeShufflePolicy.java x: 31 lines of code y: 5 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DataSkewPolicy.java x: 28 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DefaultPolicy.java x: 21 lines of code y: 5 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyBuilder.java x: 78 lines of code y: 6 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/SamplingLargeShuffleSkewPolicy.java x: 30 lines of code y: 2 # changes formatter.xml x: 397 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeTestUtil.java x: 19 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/PersistentConnectionToMasterMap.java x: 44 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageContext.java x: 21 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageDispatcher.java x: 73 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageEnvironment.java x: 54 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageSender.java x: 33 lines of code y: 3 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/state/BlockState.java x: 32 lines of code y: 4 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/state/TaskState.java x: 49 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BroadcastManagerWorker.java x: 64 lines of code y: 5 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java x: 45 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/SerializerManager.java x: 54 lines of code y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/NonSerializedPartition.java x: 69 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/Serializer.java x: 31 lines of code y: 3 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWatermarkManager.java x: 64 lines of code y: 4 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java x: 301 lines of code y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricManagerMaster.java x: 52 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraintRegistry.java x: 44 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DecoderProperty.java x: 11 lines of code y: 4 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceAntiAffinityProperty.java x: 11 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElement.java x: 7 lines of code y: 1 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/SkewCompositePass.java x: 12 lines of code y: 5 # changes webui/assets/constants.js x: 16 lines of code y: 2 # changes webui/components/environment/EnvironmentView.vue x: 32 lines of code y: 1 # changes webui/components/jobs/detail/DAG.vue x: 662 lines of code y: 1 # changes webui/components/jobs/detail/MetricTimeline.vue x: 126 lines of code y: 1 # changes webui/components/jobs/detail/StageSelect.vue x: 172 lines of code y: 1 # changes webui/components/stages/StagesView.vue x: 142 lines of code y: 1 # changes webui/plugins/vue-affix.js x: 3 lines of code y: 1 # changes common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java x: 35 lines of code y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CacheIDProperty.java x: 11 lines of code y: 2 # changes compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkSourceUtil.java x: 38 lines of code y: 2 # changes compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/PairRDDFunctions.scala x: 222 lines of code y: 2 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StageMetric.java x: 31 lines of code y: 2 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlan.java x: 35 lines of code y: 2 # changes runtime/common/src/main/proto/GrcpMessageService.proto x: 32 lines of code y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/LimitedInputStream.java x: 20 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/BroadcastManagerMaster.java x: 19 lines of code y: 2 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanAppender.java x: 80 lines of code y: 2 # changes
29.0
# changes
  min: 1.0
  average: 4.21
  25th percentile: 2.0
  median: 4.0
  75th percentile: 5.0
  max: 29.0
0 726.0
lines of code
min: 1.0 | average: 67.9 | 25th percentile: 14.0 | median: 31.0 | 75th percentile: 76.0 | max: 726.0

Number of Contributors vs. Number of Changes: 481 points

common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java x: 2 # contributors y: 3 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java x: 4 # contributors y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeContainer.java x: 5 # contributors y: 6 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDataFetcher.java x: 7 # contributors y: 12 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteOutputContext.java x: 2 # contributors y: 2 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/PipeTransferForAllEdgesPass.java x: 4 # contributors y: 6 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/StreamingScheduler.java x: 4 # contributors y: 5 # changes common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java x: 6 # contributors y: 7 # changes common/src/main/java/org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.java x: 5 # contributors y: 5 # changes common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java x: 1 # contributors y: 1 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.java x: 8 # contributors y: 13 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.java x: 3 # contributors y: 5 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java x: 6 # contributors y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockOutputWriter.java x: 6 # contributors y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/DataFetcherOutputCollector.java x: 4 # contributors y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java x: 5 # contributors y: 9 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OutputWriter.java x: 7 # contributors y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadParentTaskDataFetcher.java x: 9 # contributors y: 10 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java x: 10 # contributors y: 20 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java x: 10 # contributors y: 23 # changes client/src/main/java/org/apache/nemo/client/JobLauncher.java x: 15 # contributors y: 23 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.java x: 6 # contributors y: 11 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java x: 5 # contributors y: 7 # changes conf/src/main/java/org/apache/nemo/conf/JobConf.java x: 8 # contributors y: 14 # changes runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java x: 4 # contributors y: 7 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java x: 7 # contributors y: 9 # changes client/src/main/java/org/apache/nemo/client/ClientUtils.java x: 3 # contributors y: 3 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java x: 5 # contributors y: 10 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java x: 7 # contributors y: 14 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java x: 3 # contributors y: 9 # changes common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java x: 6 # contributors y: 10 # changes compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java x: 3 # contributors y: 6 # changes runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java x: 8 # contributors y: 16 # changes common/src/main/java/org/apache/nemo/common/ir/IRDAG.java x: 10 # contributors y: 16 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java x: 9 # contributors y: 12 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssigner.java x: 3 # contributors y: 4 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java x: 6 # contributors y: 6 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslationContext.java x: 5 # contributors y: 8 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingSkewReshapingPass.java x: 7 # contributors y: 7 # changes compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewReshapingPass.java x: 10 # contributors y: 14 # changes client/src/main/java/org/apache/nemo/client/ClientEndpoint.java x: 2 # contributors y: 4 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java x: 3 # contributors y: 8 # changes runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DirectByteBufferOutputStream.java x: 1 # contributors y: 2 # changes runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java x: 4 # contributors y: 9 # changes runtime/common/src/main/proto/ControlMessage.proto x: 10 # contributors y: 29 # changes compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.java x: 4 # contributors y: 11 # changes
29.0
# changes
  min: 1.0
  average: 4.21
  25th percentile: 2.0
  median: 4.0
  75th percentile: 5.0
  max: 29.0
0 15.0
# contributors
min: 1.0 | average: 2.91 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 4.0 | max: 15.0

Number of Contributors vs. File Size: 481 points

common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java x: 2 # contributors y: 17 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java x: 4 # contributors y: 28 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java x: 2 # contributors y: 140 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeContainer.java x: 5 # contributors y: 91 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDataFetcher.java x: 7 # contributors y: 83 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteOutputContext.java x: 2 # contributors y: 151 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java x: 2 # contributors y: 185 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ContextManager.java x: 2 # contributors y: 160 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ControlFrameEncoder.java x: 2 # contributors y: 48 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/PipeTransferForAllEdgesPass.java x: 4 # contributors y: 21 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricManagerWorker.java x: 5 # contributors y: 77 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/StreamingScheduler.java x: 4 # contributors y: 120 lines of code common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java x: 6 # contributors y: 10 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.java x: 5 # contributors y: 11 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/transform/Transform.java x: 6 # contributors y: 18 lines of code common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java x: 1 # contributors y: 54 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.java x: 8 # contributors y: 189 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.java x: 3 # contributors y: 212 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/LatencyMetric.java x: 2 # contributors y: 22 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java x: 6 # contributors y: 239 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockOutputWriter.java x: 6 # contributors y: 100 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/DataFetcherOutputCollector.java x: 4 # contributors y: 36 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventDecoderFactory.java x: 4 # contributors y: 61 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventEncoderFactory.java x: 4 # contributors y: 48 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java x: 5 # contributors y: 102 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorWatermarkCollector.java x: 4 # contributors y: 30 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OutputWriter.java x: 7 # contributors y: 11 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeOutputWriter.java x: 7 # contributors y: 108 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/RunTimeMessageOutputCollector.java x: 4 # contributors y: 77 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadParentTaskDataFetcher.java x: 9 # contributors y: 158 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java x: 10 # contributors y: 533 lines of code common/src/main/java/org/apache/nemo/common/Util.java x: 8 # contributors y: 171 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java x: 10 # contributors y: 398 lines of code client/src/main/java/org/apache/nemo/client/JobLauncher.java x: 15 # contributors y: 339 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.java x: 6 # contributors y: 81 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java x: 5 # contributors y: 25 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java x: 4 # contributors y: 33 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.java x: 6 # contributors y: 61 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapToPairTransform.java x: 5 # contributors y: 27 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceTransform.java x: 6 # contributors y: 56 lines of code conf/src/main/java/org/apache/nemo/conf/JobConf.java x: 8 # contributors y: 161 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StreamMetric.java x: 1 # contributors y: 35 lines of code runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java x: 4 # contributors y: 207 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java x: 7 # contributors y: 185 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DataUtil.java x: 5 # contributors y: 296 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/ParentTaskDataFetcher.java x: 5 # contributors y: 158 lines of code tools/network_profiling/network_clustering.py x: 1 # contributors y: 22 lines of code tools/network_profiling/network_profiling.py x: 1 # contributors y: 79 lines of code client/src/main/java/org/apache/nemo/client/ClientUtils.java x: 3 # contributors y: 56 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java x: 5 # contributors y: 396 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java x: 7 # contributors y: 346 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java x: 3 # contributors y: 229 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ExecutorRegistry.java x: 4 # contributors y: 84 lines of code common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java x: 6 # contributors y: 269 lines of code common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/SubPartitionSetProperty.java x: 2 # contributors y: 12 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java x: 8 # contributors y: 245 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryTimerInternalsFactory.java x: 2 # contributors y: 49 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.java x: 6 # contributors y: 103 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPass.java x: 2 # contributors y: 195 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalInputContext.java x: 2 # contributors y: 56 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/TransferOutputStream.java x: 2 # contributors y: 7 lines of code common/src/main/java/org/apache/nemo/common/exception/RuntimeOptimizationException.java x: 1 # contributors y: 9 lines of code common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java x: 6 # contributors y: 442 lines of code common/src/main/java/org/apache/nemo/common/ir/IdManager.java x: 4 # contributors y: 50 lines of code compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java x: 3 # contributors y: 114 lines of code compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/ParallelismProphet.java x: 1 # contributors y: 93 lines of code compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/Prophet.java x: 1 # contributors y: 5 lines of code compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/SkewProphet.java x: 1 # contributors y: 25 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/DynamicTaskSizingRuntimePass.java x: 1 # contributors y: 100 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DynamicTaskSizingPolicy.java x: 1 # contributors y: 34 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PlanRewriter.java x: 3 # contributors y: 6 lines of code runtime/driver/src/main/java/org/apache/nemo/driver/UserApplicationRunner.java x: 5 # contributors y: 71 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java x: 8 # contributors y: 234 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchSchedulerUtils.java x: 2 # contributors y: 238 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulatedTaskExecutor.java x: 2 # contributors y: 147 lines of code client/src/main/java/org/apache/reef/runtime/yarn/ClassPathBuilder.java x: 3 # contributors y: 46 lines of code common/src/main/java/org/apache/nemo/common/ir/IRDAG.java x: 10 # contributors y: 644 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java x: 9 # contributors y: 366 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssigner.java x: 3 # contributors y: 84 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java x: 6 # contributors y: 135 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteInputContext.java x: 1 # contributors y: 181 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransfer.java x: 1 # contributors y: 72 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransferContext.java x: 1 # contributors y: 128 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransportChannelInitializer.java x: 1 # contributors y: 44 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ClosableBlockingQueue.java x: 1 # contributors y: 56 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/DataFrameEncoder.java x: 1 # contributors y: 87 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalOutputContext.java x: 1 # contributors y: 49 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalTransferContext.java x: 1 # contributors y: 31 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/OutputContext.java x: 1 # contributors y: 6 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/package-info.java x: 1 # contributors y: 1 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslationContext.java x: 5 # contributors y: 188 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.java x: 1 # contributors y: 39 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.java x: 4 # contributors y: 39 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.java x: 1 # contributors y: 41 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/utility/SamplingVertex.java x: 4 # contributors y: 67 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java x: 1 # contributors y: 321 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.java x: 1 # contributors y: 18 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/SignalVertex.java x: 1 # contributors y: 13 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewHandlingUtil.java x: 6 # contributors y: 54 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewReshapingPass.java x: 10 # contributors y: 47 lines of code client/src/main/java/org/apache/nemo/client/ClientEndpoint.java x: 2 # contributors y: 76 lines of code client/src/main/java/org/apache/nemo/client/DriverEndpoint.java x: 2 # contributors y: 24 lines of code client/src/main/java/org/apache/nemo/client/beam/NemoPipelineResult.java x: 2 # contributors y: 65 lines of code client/src/main/java/org/apache/nemo/client/beam/NemoRunner.java x: 2 # contributors y: 37 lines of code common/src/main/java/org/apache/nemo/common/ir/executionproperty/ResourceSpecification.java x: 1 # contributors y: 47 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/NemoOptimizer.java x: 5 # contributors y: 150 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java x: 2 # contributors y: 59 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageUtils.java x: 1 # contributors y: 71 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/JobMetric.java x: 4 # contributors y: 108 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Task.java x: 3 # contributors y: 81 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TaskStateManager.java x: 5 # contributors y: 86 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ContainerManager.java x: 6 # contributors y: 161 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/PendingTaskCollectionPointer.java x: 3 # contributors y: 29 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java x: 1 # contributors y: 397 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java x: 5 # contributors y: 155 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java x: 4 # contributors y: 100 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockInputReader.java x: 6 # contributors y: 142 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeInputReader.java x: 5 # contributors y: 65 lines of code webui/components/MainContainer.vue x: 3 # contributors y: 91 lines of code webui/components/jobs/JobsView.vue x: 2 # contributors y: 726 lines of code webui/components/jobs/detail/JobView.vue x: 2 # contributors y: 272 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkEncoderFactory.java x: 3 # contributors y: 34 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/JavaSparkContext.java x: 3 # contributors y: 22 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkContext.java x: 3 # contributors y: 35 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaPairRDD.java x: 1 # contributors y: 511 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaRDD.java x: 1 # contributors y: 423 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/Dataset.java x: 3 # contributors y: 656 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LambdaPass.java x: 3 # contributors y: 15 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/FileBlock.java x: 6 # contributors y: 248 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkFrontendUtils.java x: 6 # contributors y: 118 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVertex.java x: 5 # contributors y: 103 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/NativeChannelImplementationSelector.java x: 3 # contributors y: 39 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamEncoderFactory.java x: 4 # contributors y: 55 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyImpl.java x: 5 # contributors y: 128 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/DataFetcher.java x: 5 # contributors y: 20 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageClient.java x: 4 # contributors y: 80 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java x: 5 # contributors y: 138 lines of code common/src/main/java/org/apache/nemo/common/StateMachine.java x: 4 # contributors y: 169 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/FileMetadata.java x: 3 # contributors y: 43 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LargeShuffleReshapingPass.java x: 4 # contributors y: 23 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/Block.java x: 3 # contributors y: 18 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageSender.java x: 3 # contributors y: 28 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.java x: 4 # contributors y: 60 lines of code common/src/main/java/org/apache/nemo/common/coder/BytesEncoderFactory.java x: 6 # contributors y: 29 lines of code common/src/main/java/org/apache/nemo/common/ir/Readable.java x: 5 # contributors y: 12 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.java x: 4 # contributors y: 74 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java x: 6 # contributors y: 214 lines of code common/src/main/java/org/apache/nemo/common/dag/DAG.java x: 4 # contributors y: 247 lines of code common/src/main/java/org/apache/nemo/common/dag/DAGInterface.java x: 3 # contributors y: 42 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/HDFSTextFileTransform.java x: 4 # contributors y: 43 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/SparkSession.java x: 4 # contributors y: 242 lines of code common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java x: 6 # contributors y: 50 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemorySideInputReader.java x: 5 # contributors y: 61 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/SerializedMemoryBlock.java x: 5 # contributors y: 144 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java x: 4 # contributors y: 135 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java x: 3 # contributors y: 306 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java x: 5 # contributors y: 100 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java x: 6 # contributors y: 182 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java x: 4 # contributors y: 196 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java x: 4 # contributors y: 190 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockMetadata.java x: 3 # contributors y: 76 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/PipeManagerMaster.java x: 3 # contributors y: 111 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/XGBoostPass.java x: 2 # contributors y: 88 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/TransientResourceCompositePass.java x: 3 # contributors y: 12 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputReader.java x: 4 # contributors y: 18 lines of code common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.java x: 4 # contributors y: 17 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java x: 3 # contributors y: 25 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourcePriorityPass.java x: 4 # contributors y: 42 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java x: 4 # contributors y: 129 lines of code common/src/main/java/org/apache/nemo/common/ByteBufferInputStream.java x: 2 # contributors y: 28 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/Policy.java x: 4 # contributors y: 8 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/NonSerializedMemoryBlock.java x: 4 # contributors y: 121 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/AntiAffinitySchedulingConstraint.java x: 2 # contributors y: 34 lines of code common/src/main/java/org/apache/nemo/common/exception/IllegalEdgeOperationException.java x: 2 # contributors y: 9 lines of code ml/nemo_xgboost_optimization.py x: 1 # contributors y: 264 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ClientRPC.java x: 1 # contributors y: 110 lines of code runtime/common/src/main/proto/ControlMessage.proto x: 10 # contributors y: 222 lines of code client/src/main/java/org/apache/nemo/client/StateTranslator.java x: 2 # contributors y: 5 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/Optimizer.java x: 3 # contributors y: 9 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/RemoteFileMetadata.java x: 2 # contributors y: 70 lines of code client/src/main/java/org/apache/nemo/client/DriverRPCServer.java x: 2 # contributors y: 120 lines of code common/src/main/java/org/apache/nemo/common/dag/Vertex.java x: 2 # contributors y: 20 lines of code common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java x: 3 # contributors y: 69 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java x: 3 # contributors y: 66 lines of code common/src/main/java/org/apache/nemo/common/ir/vertex/SourceVertex.java x: 5 # contributors y: 15 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.java x: 6 # contributors y: 123 lines of code compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.java x: 3 # contributors y: 58 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkTextFileBoundedSourceVertex.java x: 3 # contributors y: 100 lines of code compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/DataFrameReader.java x: 2 # contributors y: 271 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java x: 3 # contributors y: 209 lines of code compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/SamplingLargeShuffleSkewPolicy.java x: 2 # contributors y: 30 lines of code formatter.xml x: 3 # contributors y: 397 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/PersistentConnectionToMasterMap.java x: 2 # contributors y: 44 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageDispatcher.java x: 2 # contributors y: 73 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageEnvironment.java x: 2 # contributors y: 54 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageSender.java x: 2 # contributors y: 38 lines of code runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BroadcastManagerWorker.java x: 3 # contributors y: 64 lines of code runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java x: 2 # contributors y: 301 lines of code webui/components/jobs/detail/DAG.vue x: 1 # contributors y: 662 lines of code webui/components/jobs/detail/StageSelect.vue x: 1 # contributors y: 172 lines of code webui/components/stages/StagesView.vue x: 1 # contributors y: 142 lines of code common/src/main/java/org/apache/nemo/common/coder/DecoderFactory.java x: 1 # contributors y: 28 lines of code compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/PairRDDFunctions.scala x: 1 # contributors y: 222 lines of code runtime/common/src/main/java/org/apache/nemo/runtime/common/message/FailedMessageSender.java x: 1 # contributors y: 17 lines of code
726.0
lines of code
  min: 1.0
  average: 67.9
  25th percentile: 14.0
  median: 31.0
  75th percentile: 76.0
  max: 726.0
0 15.0
# contributors
min: 1.0 | average: 2.91 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 4.0 | max: 15.0