apache / incubator-nemo
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 11% | 29% | 22% | 36%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 8% | 27% | 23% | 40%
vue0% | 56% | 10% | 17% | 15%
scala0% | 0% | 100% | 0% | 0%
xml0% | 0% | 100% | 0% | 0%
py0% | 0% | 72% | 0% | 27%
proto0% | 0% | 87% | 0% | 12%
js0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
webui0% | 54% | 10% | 17% | 17%
compiler0% | 12% | 27% | 22% | 36%
common0% | 12% | 30% | 9% | 47%
runtime0% | 3% | 30% | 28% | 37%
ROOT0% | 0% | 100% | 0% | 0%
client0% | 0% | 40% | 14% | 45%
ml0% | 0% | 100% | 0% | 0%
conf0% | 0% | 0% | 76% | 23%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
JobsView.vue
in webui/components/jobs
 726 -
DAG.vue
in webui/components/jobs/detail
 662 -
Dataset.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 656 91
IRDAG.java
in common/src/main/java/org/apache/nemo/common/ir
 644 48
TaskExecutor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 533 20
SparkJavaPairRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 511 65
IRDAGChecker.java
in common/src/main/java/org/apache/nemo/common/ir
 442 22
SparkJavaRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 423 76
PipelineTranslator.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 398 14
SimulationScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 397 29
397 -
RDD.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
 397 18
PlanStateManager.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 396 26
BlockManagerWorker.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 366 10
RuntimeMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 346 14
JobLauncher.java
in client/src/main/java/org/apache/nemo/client
 339 20
TaskSizeSplitterVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility
 321 17
MetricUtils.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 306 15
BlockManagerMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 301 18
DataUtil.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 296 18
MemoryChunk.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 272 24
JobView.vue
in webui/components/jobs/detail
 272 -
DataFrameReader.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 271 39
DAGBuilder.java
in common/src/main/java/org/apache/nemo/common/dag
 269 22
264 23
FileBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
 248 11
DAG.java
in common/src/main/java/org/apache/nemo/common/dag
 247 28
LoopVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 245 32
SparkSession.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 242 30
TaskMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 239 41
BatchSchedulerUtils.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 238 12
BatchScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 234 13
MetricStore.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric
 229 16
proto
ControlMessage.proto
in runtime/common/src/main/proto
 222 -
PairRDDFunctions.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
 222 2
LoopOptimizations.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 214 10
GBKTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 212 15
LoopExtractionPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 209 7
NemoDriver.java
in runtime/driver/src/main/java/org/apache/nemo/driver
 207 14
PhysicalPlanGenerator.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan
 196 7
SamplingTaskSizingPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
 195 7
NcsMessageEnvironment.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs
 190 14
AbstractDoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 189 14
PipelineTranslationContext.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 188 12
ByteTransport.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 185 8
Executor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor
 185 10
ResourceSitePass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
 182 11
ByteInputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 181 11
StageSelect.vue
in webui/components/jobs/detail
 172 -
Util.java
in common/src/main/java/org/apache/nemo/common
 171 15
Files With Most Units (Top 50)
File# lines# units
Dataset.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 656 91
SparkJavaRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 423 76
SparkJavaPairRDD.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd
 511 65
IRDAG.java
in common/src/main/java/org/apache/nemo/common/ir
 644 48
TaskMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 239 41
DataFrameReader.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 271 39
LoopVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 245 32
SparkSession.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
 242 30
SimulationScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 397 29
DAG.java
in common/src/main/java/org/apache/nemo/common/dag
 247 28
PlanStateManager.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 396 26
MemoryChunk.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 272 24
264 23
IRDAGChecker.java
in common/src/main/java/org/apache/nemo/common/ir
 442 22
DAGBuilder.java
in common/src/main/java/org/apache/nemo/common/dag
 269 22
StateMachine.java
in common/src/main/java/org/apache/nemo/common
 169 21
TaskExecutor.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 533 20
JobLauncher.java
in client/src/main/java/org/apache/nemo/client
 339 20
BlockManagerMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 301 18
DataUtil.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
 296 18
RDD.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
 397 18
DefaultExecutorRepresenter.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/resource
 158 17
ByteTransferContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 128 17
TaskSizeSplitterVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility
 321 17
MetricStore.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/metric
 229 16
JobMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 108 15
MetricUtils.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
 306 15
Util.java
in common/src/main/java/org/apache/nemo/common
 171 15
ExecutionPropertyMap.java
in common/src/main/java/org/apache/nemo/common/ir/executionproperty
 126 15
GBKTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 212 15
NemoDriver.java
in runtime/driver/src/main/java/org/apache/nemo/driver
 207 14
RuntimeIdManager.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common
 59 14
NcsMessageEnvironment.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs
 190 14
RuntimeMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
 346 14
PipelineTranslator.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 398 14
AbstractDoFnTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
 189 14
BatchScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 234 13
CachedSourceVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 66 13
BeamBoundedSourceVertex.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source
 135 13
BeamUnboundedSourceVertex.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source
 123 13
BatchSchedulerUtils.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
 238 12
ContextManager.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 160 12
PipelineTranslationContext.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
 188 12
Task.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan
 81 11
ByteInputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 181 11
ByteOutputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
 151 11
MultiThreadParentTaskDataFetcher.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task
 158 11
SerializedPartition.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition
 138 11
FileBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
 248 11
InMemorySourceVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex
 76 11
Files With Long Lines (Top 6)

There are 6 files with lines longer than 120 characters. In total, there are 8 long lines.

File# lines# units# long lines
JobsView.vue
in webui/components/jobs
 726 - 3
264 23 1
MainContainer.vue
in webui/components
 91 - 1
JobView.vue
in webui/components/jobs/detail
 272 - 1
TaskStatistics.vue
in webui/components
 91 - 1
RDD.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
 397 18 1
Correlations

File Size vs. Commits (all time): 481 points

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

File Size vs. Contributors (all time): 481 points

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

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".