apache / incubator-nemo
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 480 files with 32,605 lines of code in files.
    • 480 files that are 366+ days old (32,605 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 480 files with 32,605 lines of code in files.
    • 477 files have been last changed 366+ days ago (32,420 lines of code)
    • 3 files have been last changed 181-365 days ago (185 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
99% | <1% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, vue, js, sh, json, md, scala, py, txt, yml, gitignore, proto, editorconfig, properties, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
vue100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
js100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java99% | <1% | 0% | 0% | 0%
vue100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
js100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
runtime100% | 0% | 0% | 0% | 0%
compiler100% | 0% | 0% | 0% | 0%
common100% | 0% | 0% | 0% | 0%
webui100% | 0% | 0% | 0% | 0%
client100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
ml100% | 0% | 0% | 0% | 0%
conf100% | 0% | 0% | 0% | 0%
tools100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
runtime98% | 1% | 0% | 0% | 0%
compiler100% | 0% | 0% | 0% | 0%
common99% | <1% | 0% | 0% | 0%
webui100% | 0% | 0% | 0% | 0%
client100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
ml100% | 0% | 0% | 0% | 0%
conf100% | 0% | 0% | 0% | 0%
tools100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
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
proto
GrcpMessageService.proto
in runtime/common/src/main/proto
32 - 2017-11-29 2018-10-26 6 3 jeongyoon0807@gmail.com jangho@jangho.io
397 - 2018-08-17 2019-03-27 3 3 jangho@jangho.io wonook@apache.org
Dataset.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
656 91 2018-09-06 2020-02-11 4 3 jangho@jangho.io jeongyoon0807@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
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
RDD.scala
in compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd
397 18 2018-09-06 2020-02-11 6 5 jangho@jangho.io jeongyoon0807@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
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....
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
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
BlockManagerMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
301 18 2018-09-06 2019-03-27 3 2 jangho@jangho.io wonook@apache.org
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
DataFrameReader.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
271 39 2018-09-06 2019-03-27 3 2 jangho@jangho.io wonook@apache.org
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
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
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
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
SparkSession.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql
242 30 2018-09-06 2020-01-01 5 4 jangho@jangho.io haesoo1108@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
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...
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
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....
LoopExtractionPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
209 7 2018-09-06 2019-03-27 5 3 jangho@jangho.io wonook@apache.org
NemoDriver.java
in runtime/driver/src/main/java/org/apache/nemo/driver
207 14 2018-09-06 2021-10-18 7 4 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
NcsMessageEnvironment.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs
190 14 2018-09-06 2019-10-15 6 4 jangho@jangho.io sanhaleehana@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
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
StateMachine.java
in common/src/main/java/org/apache/nemo/common
169 21 2018-09-06 2020-01-21 6 4 jangho@jangho.io 54934934+1207koo@users.nore...
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
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
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
TaskDispatcher.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
155 10 2018-09-06 2020-03-09 6 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
SerializedMemoryBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
144 8 2018-09-06 2019-12-17 6 5 jangho@jangho.io 48579185+ulgal@users.norepl...
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
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
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
CommonSubexpressionEliminationPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
129 3 2018-09-06 2019-09-09 5 4 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
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
NonSerializedMemoryBlock.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block
121 7 2018-09-06 2019-08-07 5 4 jangho@jangho.io chohy0555@gmail.com
DriverRPCServer.java
in client/src/main/java/org/apache/nemo/client
120 9 2018-09-06 2019-03-27 3 2 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
JobMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
108 15 2018-09-06 2020-03-09 7 4 jangho@jangho.io wsong0512@gmail.com
GrpcMessageServer.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc
106 7 2018-09-06 2020-01-21 5 4 jangho@jangho.io 32813753+sharkmir1@users.no...
SparkDatasetBoundedSourceVertex.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source
103 11 2018-09-06 2020-02-10 7 5 jangho@jangho.io jeongyoon0807@gmail.com
StageEdge.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/plan
100 9 2018-09-06 2020-03-07 7 4 jangho@jangho.io 43122460+polarcoke2@users.n...
SparkTextFileBoundedSourceVertex.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source
100 11 2018-09-06 2019-03-27 5 3 jangho@jangho.io wonook@apache.org
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
PubSubEventHandlerWrapper.java
in common/src/main/java/org/apache/nemo/common/eventhandler
13 2 2018-09-06 2018-09-06 1 1 jangho@jangho.io jangho@jangho.io
RuntimeEvent.java
in common/src/main/java/org/apache/nemo/common/eventhandler
3 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
CompilerEvent.java
in common/src/main/java/org/apache/nemo/common/eventhandler
3 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
Cloneable.java
in common/src/main/java/org/apache/nemo/common
4 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
RemoteFileStore.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores
5 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
UnsupportedCompressionException.java
in common/src/main/java/org/apache/nemo/common/exception
6 1 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
BlockFetchException.java
in common/src/main/java/org/apache/nemo/common/exception
6 1 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
BlockWriteException.java
in common/src/main/java/org/apache/nemo/common/exception
6 1 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
DecodeStreamChainer.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer
6 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
EncodeStreamChainer.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer
6 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
MessageParameters.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message
8 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
CompileTimeOptimizationException.java
in common/src/main/java/org/apache/nemo/common/exception
9 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
DynamicOptimizationException.java
in common/src/main/java/org/apache/nemo/common/exception
9 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
WebSocketMetricServlet.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet
9 1 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
PlanAppenderException.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/exception
9 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
DecompressionProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
10 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
CacheIDProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
11 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
KeyDecoderProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
11 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
KeyExtractorProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
11 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
KeyEncoderProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
11 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
BlockStore.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores
11 - 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
FailedMessageSender.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/message
17 3 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
BroadcastManagerMaster.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master
19 3 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
FreeSlotSchedulingConstraint.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
19 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
LimitedInputStream.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
20 2 2018-09-06 2018-10-26 2 1 jangho@jangho.io jangho@jangho.io
NemoClient.java
in client/src/main/java/org/apache/nemo/client
21 2 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
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
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
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
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
proto
GrcpMessageService.proto
in runtime/common/src/main/proto
32 - 2017-11-29 2018-10-26 6 3 jeongyoon0807@gmail.com 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
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
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
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
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
AssociatedProperty.java
in common/src/main/java/org/apache/nemo/common/ir/executionproperty
8 - 2018-09-06 2018-12-06 3 2 jangho@jangho.io egjung49@gmail.com
Requires.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime
9 - 2018-09-06 2018-12-06 3 2 jangho@jangho.io egjung49@gmail.com
Annotates.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
9 - 2018-09-06 2018-12-06 3 2 jangho@jangho.io egjung49@gmail.com
Finishmark.java
in common/src/main/java/org/apache/nemo/common/punctuation
9 2 2018-10-29 2018-12-06 2 2 taegeonum@gmail.com egjung49@gmail.com
NemoPipelineOptions.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam
14 - 2018-09-06 2018-12-06 4 3 jangho@jangho.io egjung49@gmail.com
SparkBroadcastVariables.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark
23 3 2018-09-06 2018-12-06 3 2 jangho@jangho.io egjung49@gmail.com
Watermark.java
in common/src/main/java/org/apache/nemo/common/punctuation
35 6 2018-10-29 2018-12-06 5 3 taegeonum@gmail.com egjung49@gmail.com
vue-affix.js
in webui/plugins
3 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
vue2vis.js
in webui/plugins
3 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
element-ui.js
in webui/plugins
4 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
event-bus.js
in webui/plugins
6 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
index.vue
in webui/pages
13 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
39 - 2018-12-14 2018-12-14 1 1 1418874+skystar-p@users.nor... 1418874+skystar-p@users.nor...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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
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
LatencyMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
22 4 2021-10-18 2022-08-01 2 2 goehd4551@gmail.com wsong0512@gmail.com
LatencymarkEmitTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
17 3 2021-10-18 2022-09-22 3 2 goehd4551@gmail.com wsong0512@gmail.com
network_profiling.py
in tools/network_profiling
79 2 2021-08-16 2021-08-16 1 1 wsong0512@gmail.com wsong0512@gmail.com
network_clustering.py
in tools/network_profiling
22 - 2021-08-16 2021-08-16 1 1 wsong0512@gmail.com wsong0512@gmail.com
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...
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...
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...
SkewProphet.java
in compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet
25 2 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
RuntimeOptimizationException.java
in common/src/main/java/org/apache/nemo/common/exception
9 2 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
Prophet.java
in compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet
5 - 2020-11-24 2020-11-24 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
ByteTransport.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
185 8 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
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....
ContextManager.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
160 12 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
ByteOutputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
151 11 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
FrameDecoder.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
140 5 2020-11-19 2022-08-29 3 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
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....
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....
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....
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....
LocalInputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
56 5 2020-11-19 2020-12-11 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
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....
ControlFrameEncoder.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
48 2 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... 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....
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....
TransferOutputStream.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
7 - 2020-11-19 2020-12-11 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
OutputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
6 - 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
package-info.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
1 - 2020-11-19 2020-11-19 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
GBKTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
212 15 2020-10-14 2022-08-01 5 3 60352009+jaehwan0214@users.... wsong0512@gmail.com
InMemoryTimerInternalsFactory.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
49 4 2020-10-14 2020-12-11 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
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....
InMemoryStateInternalsFactory.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
23 3 2020-10-14 2020-10-14 1 1 60352009+jaehwan0214@users.... 60352009+jaehwan0214@users....
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...
SamplingTaskSizingPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping
195 7 2020-07-03 2020-12-11 3 2 43122460+polarcoke2@users.n... wsong0512@gmail.com
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...
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...
MessageAggregatorVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass
25 1 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
MessageGeneratorVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass
18 2 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
SignalVertex.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass
13 1 2020-07-03 2020-07-03 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
OutputMismatchException.java
in common/src/main/java/org/apache/nemo/common/exception
9 2 2020-03-25 2020-03-25 1 1 wonook@apache.org wonook@apache.org
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
BatchSchedulerUtils.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
238 12 2020-03-09 2020-11-24 2 2 wsong0512@gmail.com 43122460+polarcoke2@users.n...
SimulatedTaskExecutor.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
147 6 2020-03-09 2020-11-24 2 2 wsong0512@gmail.com 43122460+polarcoke2@users.n...
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
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
SimulationException.java
in common/src/main/java/org/apache/nemo/common/exception
9 2 2020-03-09 2020-03-09 1 1 wsong0512@gmail.com wsong0512@gmail.com
SubPartitionSetProperty.java
in common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty
12 2 2020-03-07 2020-12-11 2 2 43122460+polarcoke2@users.n... wsong0512@gmail.com
EnableDynamicTaskSizingProperty.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty
10 2 2020-03-07 2020-03-07 1 1 43122460+polarcoke2@users.n... 43122460+polarcoke2@users.n...
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
StreamTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
28 5 2019-02-01 2022-09-22 4 4 johnyangk@gmail.com wsong0512@gmail.com
LatencymarkEmitTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
17 3 2021-10-18 2022-09-22 3 2 goehd4551@gmail.com wsong0512@gmail.com
FrameDecoder.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
140 5 2020-11-19 2022-08-29 3 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
ByteTransport.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
185 8 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
ContextManager.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
160 12 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
ByteOutputContext.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
151 11 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... wsong0512@gmail.com
PipeContainer.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data
91 7 2018-10-30 2022-08-02 6 5 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
ControlFrameEncoder.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer
48 2 2020-11-19 2022-08-02 2 2 60352009+jaehwan0214@users.... 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
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
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
GBKTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
212 15 2020-10-14 2022-08-01 5 3 60352009+jaehwan0214@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
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
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
StreamingScheduler.java
in runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler
120 7 2018-10-24 2022-08-01 5 4 johnyangk@gmail.com 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
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
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
RunTimeMessageOutputCollector.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
77 5 2019-02-07 2022-08-01 4 4 johnyangk@gmail.com wsong0512@gmail.com
MetricManagerWorker.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor
77 5 2018-09-06 2022-08-01 6 5 jangho@jangho.io wsong0512@gmail.com
NemoEventDecoderFactory.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
61 5 2018-11-13 2022-08-01 4 4 taegeonum@gmail.com wsong0512@gmail.com
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
NemoEventEncoderFactory.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
48 4 2018-11-13 2022-08-01 6 4 taegeonum@gmail.com wsong0512@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
OperatorWatermarkCollector.java
in runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer
30 5 2018-11-13 2022-08-01 4 4 taegeonum@gmail.com wsong0512@gmail.com
LatencyMetric.java
in runtime/common/src/main/java/org/apache/nemo/runtime/common/metric
22 4 2021-10-18 2022-08-01 2 2 goehd4551@gmail.com wsong0512@gmail.com
PipeTransferForAllEdgesPass.java
in compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating
21 2 2018-10-30 2022-08-01 6 4 johnyangk@gmail.com wsong0512@gmail.com
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
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
NoWatermarkEmitTransform.java
in common/src/main/java/org/apache/nemo/common/ir/vertex/transform
11 2 2018-10-30 2022-08-01 5 5 taegeonum@gmail.com 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
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
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
NemoDriver.java
in runtime/driver/src/main/java/org/apache/nemo/driver
207 14 2018-09-06 2021-10-18 7 4 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
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
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
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
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
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
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
SideInputTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
33 5 2018-11-21 2021-10-18 4 4 johnyangk@gmail.com goehd4551@gmail.com
MapToPairTransform.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform
27 4 2018-09-06 2021-10-18 6 5 jangho@jangho.io goehd4551@gmail.com
FlattenTransform.java
in compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform
25 5 2018-09-06 2021-10-18 7 5 jangho@jangho.io goehd4551@gmail.com
FlatMapTransform.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform
25 4 2018-09-06 2021-10-18 6 5 jangho@jangho.io goehd4551@gmail.com
MapTransform.java
in compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform
25 4 2018-09-06 2021-10-18 6 5 jangho@jangho.io goehd4551@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
network_profiling.py
in tools/network_profiling
79 2 2021-08-16 2021-08-16 1 1 wsong0512@gmail.com wsong0512@gmail.com