path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor tools/network_profiling/network_clustering.py 22 1 725 725 1 1 2021-08-16 2021-08-16 wsong0512@gmail.com wsong0512@gmail.com tools/network_profiling/network_profiling.py 79 1 725 725 1 1 2021-08-16 2021-08-16 wsong0512@gmail.com wsong0512@gmail.com runtime/driver/src/main/java/org/apache/nemo/driver/RemoteClientMessageLoggingHandler.java 31 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/driver/src/main/java/org/apache/nemo/driver/UserApplicationRunner.java 71 10 1800 990 10 5 2018-09-06 2020-11-24 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com runtime/driver/src/main/java/org/apache/nemo/driver/NemoContext.java 56 4 1800 1303 4 3 2018-09-06 2020-01-16 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com runtime/driver/src/main/java/org/apache/nemo/driver/NemoDriver.java 207 7 1800 662 7 4 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com runtime/common/src/main/proto/GrcpMessageService.proto 32 6 2081 1750 6 3 2017-11-29 2018-10-26 jeongyoon0807@gmail.com jangho@jangho.io runtime/common/src/main/proto/ControlMessage.proto 222 29 2081 1595 32 10 2017-11-29 2019-03-30 jeongyoon0807@gmail.com wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/NativeChannelImplementationSelector.java 39 4 1800 1278 4 3 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/RuntimeEdge.java 43 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Stage.java 83 7 1800 1252 7 4 2018-09-06 2020-03-07 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PlanRewriter.java 6 3 1646 990 4 3 2019-02-07 2020-11-24 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGenerator.java 196 9 1800 1389 9 4 2018-09-06 2019-10-22 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/PhysicalPlan.java 35 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StagePartitioner.java 63 7 1800 1396 7 5 2018-09-06 2019-10-15 jangho@jangho.io sanhaleehana@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/Task.java 81 4 1800 1250 4 3 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/plan/StageEdge.java 100 7 1800 1252 7 4 2018-09-06 2020-03-07 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeTestUtil.java 19 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/RuntimeIdManager.java 59 3 1800 1250 3 2 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ClientRPC.java 110 1 1595 1595 1 1 2019-03-30 2019-03-30 wonook@apache.org wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageContext.java 4 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageSender.java 28 4 1800 1298 4 3 2018-09-06 2020-01-21 jangho@jangho.io 48665265+dkwanm1@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageEnvironment.java 70 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageServer.java 106 5 1800 1298 5 4 2018-09-06 2020-01-21 jangho@jangho.io 32813753+sharkmir1@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageContext.java 21 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/grpc/GrpcMessageClient.java 80 5 1800 1283 6 4 2018-09-06 2020-02-05 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageParameters.java 8 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageListener.java 5 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageEnvironment.java 17 5 1800 1523 5 4 2018-09-06 2019-06-10 jangho@jangho.io taegeonum@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageContext.java 20 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageDispatcher.java 73 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageSender.java 38 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/local/LocalMessageEnvironment.java 54 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageUtils.java 71 1 1250 1250 1 1 2020-03-09 2020-03-09 wsong0512@gmail.com wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/ControlMessageCodec.java 21 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageSender.java 33 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageContext.java 34 4 1800 1278 4 3 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/ncs/NcsMessageEnvironment.java 190 6 1800 1396 6 4 2018-09-06 2019-10-15 jangho@jangho.io sanhaleehana@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/MessageSender.java 7 4 1800 1298 4 3 2018-09-06 2020-01-21 jangho@jangho.io 48665265+dkwanm1@users.noreply.github.com runtime/common/src/main/java/org/apache/nemo/runtime/common/message/FailedMessageSender.java 17 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/message/PersistentConnectionToMasterMap.java 44 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/state/BlockState.java 32 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/state/PlanState.java 36 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/state/TaskState.java 49 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/state/StageState.java 33 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/ReplyFutureMap.java 20 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/NettyChannelImplementationSelector.java 12 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/TaskMetric.java 239 8 1800 375 8 6 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StateTransitionEvent.java 17 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/DataTransferEvent.java 20 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/Metric.java 5 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/Event.java 14 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StageMetric.java 31 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StateMetric.java 7 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/StreamMetric.java 35 1 662 662 1 1 2021-10-18 2021-10-18 goehd4551@gmail.com goehd4551@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/JobMetric.java 108 7 1800 1250 7 4 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/LatencyMetric.java 22 2 662 375 2 2 2021-10-18 2022-08-01 goehd4551@gmail.com wsong0512@gmail.com runtime/common/src/main/java/org/apache/nemo/runtime/common/metric/MetricUtils.java 306 8 1638 1344 9 3 2019-02-15 2019-12-06 wonook@apache.org bdv111@snu.ac.kr runtime/common/src/main/java/org/apache/nemo/runtime/common/exception/AbsentBlockException.java 16 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/common/src/main/java/org/apache/nemo/runtime/common/exception/PlanAppenderException.java 9 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/common/src/main/java/org/apache/nemo/runtime/common/NioChannelImplementationSelector.java 26 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/TaskMetricServlet.java 17 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/WebSocketMetricServlet.java 9 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/WebSocketMetricAdapter.java 36 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/AllMetricServlet.java 16 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/JobMetricServlet.java 17 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/servlet/StageMetricServlet.java 17 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockMetadata.java 76 4 1800 1396 4 3 2018-09-06 2019-10-15 jangho@jangho.io sanhaleehana@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanStateManager.java 396 10 1800 725 11 5 2018-09-06 2021-08-16 jangho@jangho.io wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/StreamingScheduler.java 120 5 1752 375 5 4 2018-10-24 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/TaskDispatcher.java 155 6 1800 1250 6 5 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ContainerTypeAwareSchedulingConstraint.java 19 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/MinOccupancyFirstSchedulingPolicy.java 29 4 1800 1277 4 3 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulationScheduler.java 397 1 1250 1250 1 1 2020-03-09 2020-03-09 wsong0512@gmail.com wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/PendingTaskCollectionPointer.java 29 4 1800 1250 4 3 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchScheduler.java 234 16 1800 990 16 8 2018-09-06 2020-11-24 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/Scheduler.java 21 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/NodeShareSchedulingConstraint.java 45 4 1800 1519 4 3 2018-09-06 2019-06-14 jangho@jangho.io johnyangk@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/FreeSlotSchedulingConstraint.java 19 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SimulatedTaskExecutor.java 147 2 1250 990 2 2 2020-03-09 2020-11-24 wsong0512@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraintRegistry.java 44 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/LocalitySchedulingConstraint.java 89 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/AntiAffinitySchedulingConstraint.java 34 2 1646 1519 2 2 2019-02-07 2019-06-14 johnyangk@gmail.com johnyangk@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/BatchSchedulerUtils.java 238 2 1250 990 2 2 2020-03-09 2020-11-24 wsong0512@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraint.java 11 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/SchedulingPolicy.java 14 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/scheduler/ExecutorRegistry.java 84 5 1800 861 5 4 2018-09-06 2021-04-02 jangho@jangho.io goehd4551@naver.com runtime/master/src/main/java/org/apache/nemo/runtime/master/PipeManagerMaster.java 111 3 1746 1396 3 3 2018-10-30 2019-10-15 johnyangk@gmail.com sanhaleehana@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/BroadcastManagerMaster.java 19 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/master/src/main/java/org/apache/nemo/runtime/master/BlockManagerMaster.java 301 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/PlanAppender.java 80 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/DefaultExecutorRepresenter.java 158 2 1461 1250 2 2 2019-08-11 2020-03-09 alapha23@gmail.com wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ExecutorRepresenter.java 19 7 1800 1461 7 4 2018-09-06 2019-08-11 jangho@jangho.io alapha23@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/resource/ContainerManager.java 161 7 1800 1250 7 6 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricBroadcaster.java 49 2 1638 1598 2 1 2019-02-15 2019-03-27 wonook@apache.org wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricManagerMaster.java 52 2 1638 1598 2 1 2019-02-15 2019-03-27 wonook@apache.org wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricStore.java 229 9 1638 861 10 3 2019-02-15 2021-04-02 wonook@apache.org goehd4551@naver.com runtime/master/src/main/java/org/apache/nemo/runtime/master/metric/MetricMessageHandler.java 8 2 1638 1598 3 1 2019-02-15 2019-03-27 wonook@apache.org wonook@apache.org runtime/master/src/main/java/org/apache/nemo/runtime/master/RuntimeMaster.java 346 14 1800 861 14 7 2018-09-06 2021-04-02 jangho@jangho.io goehd4551@naver.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TransformContextImpl.java 25 3 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ControlFrameEncoder.java 48 2 995 374 2 2 2020-11-19 2022-08-02 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/TransferOutputStream.java 7 2 995 973 2 2 2020-11-19 2020-12-11 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransport.java 185 2 995 374 2 2 2020-11-19 2022-08-02 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/DataFrameEncoder.java 87 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ContextManager.java 160 2 995 374 2 2 2020-11-19 2022-08-02 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalOutputContext.java 49 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteInputContext.java 181 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ClosableBlockingQueue.java 56 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransfer.java 72 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalInputContext.java 56 2 995 973 2 2 2020-11-19 2020-12-11 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/OutputContext.java 6 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteOutputContext.java 151 2 995 374 2 2 2020-11-19 2022-08-02 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransferContext.java 128 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/ByteTransportChannelInitializer.java 44 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/package-info.java 1 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/LocalTransferContext.java 31 1 995 995 1 1 2020-11-19 2020-11-19 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/transfer/FrameDecoder.java 140 3 995 347 3 2 2020-11-19 2022-08-29 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/IntermediateDataIOFactory.java 46 4 1746 1252 4 4 2018-10-30 2020-03-07 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/DataFetcherOutputCollector.java 36 8 1748 375 8 4 2018-10-28 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorWatermarkCollector.java 30 4 1732 375 4 4 2018-11-13 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/SingleInputWatermarkManager.java 17 4 1744 1598 4 3 2018-11-01 2019-03-27 taegeonum@gmail.com wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputWatermarkManager.java 5 3 1744 1598 3 2 2018-11-01 2019-03-27 taegeonum@gmail.com wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventEncoderFactory.java 48 6 1732 375 6 4 2018-11-13 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/InputReader.java 18 5 1800 1417 5 4 2018-09-06 2019-09-24 jangho@jangho.io johnyangk@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/WatermarkWithIndex.java 25 1 1732 1732 1 1 2018-11-13 2018-11-13 taegeonum@gmail.com taegeonum@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NextIntraTaskOperatorInfo.java 23 2 1744 1598 2 2 2018-11-01 2019-03-27 taegeonum@gmail.com wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeOutputWriter.java 108 12 1746 375 13 7 2018-10-30 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockInputReader.java 142 7 1746 1252 7 6 2018-10-30 2020-03-07 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/RunTimeMessageOutputCollector.java 77 4 1646 375 4 4 2019-02-07 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OutputWriter.java 11 8 1800 375 9 7 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/OperatorVertexOutputCollector.java 102 9 1748 375 9 5 2018-10-28 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NemoEventDecoderFactory.java 61 4 1732 375 4 4 2018-11-13 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWatermarkManager.java 64 4 1744 1598 4 3 2018-11-01 2019-03-27 taegeonum@gmail.com wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/PipeInputReader.java 65 5 1746 1252 5 5 2018-10-30 2020-03-07 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/BlockOutputWriter.java 100 9 1746 375 9 6 2018-10-30 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricMessageSender.java 8 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/MetricManagerWorker.java 77 6 1800 375 6 5 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/MultiThreadParentTaskDataFetcher.java 158 10 1744 375 10 9 2018-11-01 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java 533 20 1800 375 24 10 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/VertexHarness.java 46 3 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/DataFetcher.java 20 7 1800 1282 7 5 2018-09-06 2020-02-06 jangho@jangho.io xiangmu97@naver.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/ParentTaskDataFetcher.java 158 9 1800 662 9 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/SourceVertexDataFetcher.java 83 12 1800 374 12 7 2018-09-06 2022-08-02 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/Executor.java 185 9 1800 662 9 7 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/TaskStateManager.java 86 6 1800 1250 6 5 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BroadcastManagerWorker.java 64 5 1800 1598 6 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockManagerWorker.java 366 12 1800 995 12 9 2018-09-06 2020-11-19 jangho@jangho.io 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeContainer.java 91 6 1746 374 6 5 2018-10-30 2022-08-02 johnyangk@gmail.com wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssigner.java 84 4 1465 995 4 3 2019-08-07 2020-11-19 chohy0555@gmail.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/DecompressionStreamChainer.java 26 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/CompressionStreamChainer.java 26 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/EncodeStreamChainer.java 6 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/DecodeStreamChainer.java 6 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/streamchainer/Serializer.java 31 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryAllocationException.java 6 1 1465 1465 1 1 2019-08-07 2019-08-07 chohy0555@gmail.com chohy0555@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DataUtil.java 296 9 1800 662 10 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/BlockTransferThrottler.java 44 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/MemoryStore.java 38 5 1800 1344 5 4 2018-09-06 2019-12-06 jangho@jangho.io bdv111@snu.ac.kr runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/RemoteFileStore.java 5 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalBlockStore.java 23 3 1800 1465 3 2 2018-09-06 2019-08-07 jangho@jangho.io chohy0555@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/BlockStore.java 11 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/LocalFileStore.java 60 6 1800 1312 6 4 2018-09-06 2020-01-07 jangho@jangho.io 43238893+tyj9327@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/AbstractBlockStore.java 21 4 1800 1465 4 3 2018-09-06 2019-08-07 jangho@jangho.io chohy0555@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/GlusterFileStore.java 85 6 1800 1303 6 4 2018-09-06 2020-01-16 jangho@jangho.io 5348027+taehioum@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/stores/SerializedMemoryStore.java 39 5 1800 1344 5 4 2018-09-06 2019-12-06 jangho@jangho.io bdv111@snu.ac.kr runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/MemoryChunk.java 272 4 1465 1283 5 2 2019-08-07 2020-02-05 chohy0555@gmail.com wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/LimitedInputStream.java 20 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/SerializerManager.java 54 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/Partition.java 9 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/NonSerializedPartition.java 69 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/partition/SerializedPartition.java 138 9 1800 1388 9 5 2018-09-06 2019-10-23 jangho@jangho.io chohy0555@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/PipeManagerWorker.java 135 6 1746 995 6 6 2018-10-30 2020-11-19 johnyangk@gmail.com 60352009+jaehwan0214@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/FileArea.java 45 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/RemoteFileMetadata.java 70 3 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/LocalFileMetadata.java 16 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/PartitionMetadata.java 34 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/metadata/FileMetadata.java 43 4 1800 1298 4 3 2018-09-06 2020-01-21 jangho@jangho.io 54934934+1207koo@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/NonSerializedMemoryBlock.java 121 5 1800 1465 5 4 2018-09-06 2019-08-07 jangho@jangho.io chohy0555@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/SerializedMemoryBlock.java 144 6 1800 1333 6 5 2018-09-06 2019-12-17 jangho@jangho.io 48579185+ulgal@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/FileBlock.java 248 8 1800 1277 9 6 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/block/Block.java 18 4 1800 1298 4 3 2018-09-06 2020-01-21 jangho@jangho.io 37951125+sanggggg@users.noreply.github.com runtime/executor/src/main/java/org/apache/nemo/runtime/executor/data/DirectByteBufferOutputStream.java 99 2 1465 1388 2 1 2019-08-07 2019-10-23 chohy0555@gmail.com chohy0555@gmail.com formatter.xml 397 3 1820 1598 3 3 2018-08-17 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/KeyExtractor.java 5 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/HashRange.java 62 6 1800 1598 6 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/Util.java 171 13 1670 375 14 8 2019-01-14 2022-08-01 2631737+arunlakshman@users.noreply.github.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/Pair.java 36 4 1800 1333 4 3 2018-09-06 2019-12-17 jangho@jangho.io 48579185+ulgal@users.noreply.github.com common/src/main/java/org/apache/nemo/common/pass/Pass.java 19 6 1800 1312 6 5 2018-09-06 2020-01-07 jangho@jangho.io kdh9949@snu.ac.kr common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElementPartitioner.java 12 1 1646 1646 1 1 2019-02-07 2019-02-07 johnyangk@gmail.com johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/partitioner/DedicatedKeyPerElement.java 7 1 1646 1646 1 1 2019-02-07 2019-02-07 johnyangk@gmail.com johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/partitioner/Partitioner.java 43 4 1646 1396 4 4 2019-02-07 2019-10-15 johnyangk@gmail.com sanhaleehana@gmail.com common/src/main/java/org/apache/nemo/common/partitioner/IntactPartitioner.java 7 1 1646 1646 1 1 2019-02-07 2019-02-07 johnyangk@gmail.com johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/partitioner/HashPartitioner.java 15 2 1646 1598 2 2 2019-02-07 2019-03-27 johnyangk@gmail.com wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/IdManager.java 50 7 1800 990 7 4 2018-09-06 2020-11-24 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/IRDAG.java 644 16 1652 995 16 10 2019-02-01 2020-11-19 johnyangk@gmail.com 60352009+jaehwan0214@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/BoundedIteratorReadable.java 18 3 1747 1598 3 2 2018-10-29 2019-03-27 taegeonum@gmail.com wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionProperty.java 35 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/executionproperty/ResourceSpecification.java 47 1 1250 1250 1 1 2020-03-09 2020-03-09 wsong0512@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.java 7 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.java 7 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.java 126 8 1800 1432 8 5 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/executionproperty/AssociatedProperty.java 8 3 1800 1709 3 2 2018-09-06 2018-12-06 jangho@jangho.io egjung49@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/IREdge.java 69 6 1800 1598 6 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupProperty.java 10 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CommunicationPatternProperty.java 16 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/EncoderProperty.java 11 4 1800 1619 4 3 2018-09-06 2019-03-06 jangho@jangho.io johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataFlowProperty.java 14 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyEncoderProperty.java 11 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CompressionProperty.java 15 3 1800 1432 3 2 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupPropertyValue.java 49 3 1800 1619 3 2 2018-09-06 2019-03-06 jangho@jangho.io johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DecoderProperty.java 11 4 1800 1619 4 3 2018-09-06 2019-03-06 jangho@jangho.io johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/PartitionerProperty.java 30 6 1800 1432 6 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyExtractorProperty.java 11 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.java 17 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/MessageIdEdgeProperty.java 11 3 1632 1598 3 2 2019-02-21 2019-03-27 johnyangk@gmail.com wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/KeyDecoderProperty.java 11 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DecompressionProperty.java 10 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/PartitionSetProperty.java 12 2 1646 1598 2 2 2019-02-07 2019-03-27 johnyangk@gmail.com wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/DataPersistenceProperty.java 14 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/BlockFetchFailureProperty.java 14 1 1417 1417 1 1 2019-09-24 2019-09-24 johnyangk@apache.org johnyangk@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/AdditionalOutputTagProperty.java 14 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/CacheIDProperty.java 11 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/ir/edge/executionproperty/SubPartitionSetProperty.java 12 2 1252 973 2 2 2020-03-07 2020-12-11 43122460+polarcoke2@users.noreply.github.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/Readable.java 12 7 1800 1306 7 5 2018-09-06 2020-01-13 jangho@jangho.io 43871098+byungheecha@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/MessageIdVertexProperty.java 10 2 1632 1598 2 2 2019-02-21 2019-03-27 johnyangk@gmail.com wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceAntiAffinityProperty.java 11 1 1646 1646 1 1 2019-02-07 2019-02-07 johnyangk@gmail.com johnyangk@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ParallelismProperty.java 10 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/EnableDynamicTaskSizingProperty.java 10 1 1252 1252 1 1 2020-03-07 2020-03-07 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ScheduleGroupProperty.java 10 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourcePriorityProperty.java 14 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceSiteProperty.java 11 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLambdaProperty.java 14 2 1526 1432 2 2 2019-06-07 2019-09-09 alapha23@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceSlotProperty.java 13 4 1800 1595 4 2 2018-09-06 2019-03-30 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ResourceLocalityProperty.java 12 3 1800 1595 3 2 2018-09-06 2019-03-30 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/IgnoreSchedulingTempDataReceiverProperty.java 15 3 1800 1595 3 2 2018-09-06 2019-03-30 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.java 77 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/SourceVertex.java 15 7 1800 1598 7 5 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/CachedSourceVertex.java 66 6 1800 1598 6 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/LoopVertex.java 245 14 1800 973 14 8 2018-09-06 2020-12-11 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/InMemorySourceVertex.java 76 6 1800 1300 6 4 2018-09-06 2020-01-19 jangho@jangho.io yunsoo3042@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/IRVertex.java 50 8 1800 1595 8 4 2018-09-06 2019-03-30 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/transform/Transform.java 18 7 1800 375 8 6 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/StreamTransform.java 28 4 1652 323 4 4 2019-02-01 2022-09-22 johnyangk@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/SignalTransform.java 29 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.java 17 3 662 323 3 2 2021-10-18 2022-09-22 goehd4551@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.java 39 4 1652 1134 4 4 2019-02-01 2020-07-03 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.java 11 5 1746 375 5 5 2018-10-30 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.java 41 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/OperatorVertex.java 27 6 1800 1598 6 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/ir/vertex/utility/SamplingVertex.java 67 5 1632 1134 5 4 2019-02-21 2020-07-03 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageAggregatorVertex.java 25 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.java 18 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/utility/runtimepass/SignalVertex.java 13 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.java 321 1 1134 1134 1 1 2020-07-03 2020-07-03 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/vertex/utility/RelayVertex.java 8 1 1526 1526 1 1 2019-06-07 2019-06-07 johnyangk@apache.org johnyangk@apache.org common/src/main/java/org/apache/nemo/common/ir/IRDAGChecker.java 442 8 1619 990 8 6 2019-03-06 2020-11-24 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/ir/OutputCollector.java 10 7 1800 375 7 6 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/dag/DAGInterface.java 42 5 1652 1312 6 3 2019-02-01 2020-01-07 johnyangk@gmail.com kdh9949@snu.ac.kr common/src/main/java/org/apache/nemo/common/dag/DAG.java 247 8 1800 1312 9 4 2018-09-06 2020-01-07 jangho@jangho.io kdh9949@snu.ac.kr common/src/main/java/org/apache/nemo/common/dag/DAGBuilder.java 269 10 1800 973 10 6 2018-09-06 2020-12-11 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/dag/Vertex.java 20 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/dag/Edge.java 33 4 1800 1598 4 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/KeyRange.java 14 4 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/StateMachine.java 169 6 1800 1298 6 4 2018-09-06 2020-01-21 jangho@jangho.io 54934934+1207koo@users.noreply.github.com common/src/main/java/org/apache/nemo/common/Cloneable.java 4 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/punctuation/Watermark.java 35 5 1747 1709 5 3 2018-10-29 2018-12-06 taegeonum@gmail.com egjung49@gmail.com common/src/main/java/org/apache/nemo/common/punctuation/LatencyMark.java 54 1 375 375 1 1 2022-08-01 2022-08-01 wsong0512@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/punctuation/Finishmark.java 9 2 1747 1709 2 2 2018-10-29 2018-12-06 taegeonum@gmail.com egjung49@gmail.com common/src/main/java/org/apache/nemo/common/coder/BytesEncoderFactory.java 29 8 1800 1300 8 6 2018-09-06 2020-01-19 jangho@jangho.io yunsoo3042@gmail.com common/src/main/java/org/apache/nemo/common/coder/DecoderFactory.java 28 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/coder/EncoderFactory.java 28 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/coder/BytesDecoderFactory.java 50 10 1800 1333 10 6 2018-09-06 2019-12-17 jangho@jangho.io 48579185+ulgal@users.noreply.github.com common/src/main/java/org/apache/nemo/common/coder/LongEncoderFactory.java 30 6 1800 1278 6 4 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com common/src/main/java/org/apache/nemo/common/coder/LongDecoderFactory.java 30 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/coder/PairDecoderFactory.java 49 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/coder/IntEncoderFactory.java 30 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/coder/PairEncoderFactory.java 51 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/coder/IntDecoderFactory.java 30 6 1800 1282 6 4 2018-09-06 2020-02-06 jangho@jangho.io 54828276+ske-kr@users.noreply.github.com common/src/main/java/org/apache/nemo/common/eventhandler/CommonEventHandler.java 5 2 1800 1598 2 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/eventhandler/CompilerEvent.java 3 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/eventhandler/RuntimeEvent.java 3 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/eventhandler/RuntimeEventHandler.java 3 2 1800 1598 2 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/eventhandler/PubSubEventHandlerWrapper.java 13 1 1800 1800 1 1 2018-09-06 2018-09-06 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/eventhandler/CompilerEventHandler.java 3 2 1800 1598 2 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/MetricException.java 9 2 1638 1598 2 1 2019-02-15 2019-03-27 wonook@apache.org wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/UnsupportedMethodException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/BlockWriteException.java 6 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/exception/UnsupportedMetricException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/IllegalEdgeOperationException.java 9 4 1800 1595 4 2 2018-09-06 2019-03-30 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/DataSourceException.java 6 1 1277 1277 1 1 2020-02-11 2020-02-11 jeongyoon0807@gmail.com jeongyoon0807@gmail.com common/src/main/java/org/apache/nemo/common/exception/InvalidParameterException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/RuntimeOptimizationException.java 9 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com common/src/main/java/org/apache/nemo/common/exception/SimulationException.java 9 1 1250 1250 1 1 2020-03-09 2020-03-09 wsong0512@gmail.com wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/exception/UnsupportedExecutionPropertyException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/UnsupportedCommPatternException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/UnknownExecutionStateException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/SchedulingException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/UnsupportedBlockStoreException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/IllegalMessageException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/BlockFetchException.java 6 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/exception/UnsupportedPartitionerException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/IllegalStateTransitionException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/ContainerException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/InvalidUserMainException.java 9 1 1282 1282 1 1 2020-02-06 2020-02-06 yunseong@apache.org yunseong@apache.org common/src/main/java/org/apache/nemo/common/exception/UnsupportedCompressionException.java 6 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/exception/UnrecoverableFailureException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/DynamicOptimizationException.java 9 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/exception/CompileTimeOptimizationException.java 9 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io common/src/main/java/org/apache/nemo/common/exception/PhysicalPlanGenerationException.java 9 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/IllegalVertexOperationException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/JsonParseException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/OutputMismatchException.java 9 1 1234 1234 1 1 2020-03-25 2020-03-25 wonook@apache.org wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/UnknownFailureCauseException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/exception/NodeConnectionException.java 6 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org common/src/main/java/org/apache/nemo/common/PairKeyExtractor.java 23 2 1638 1432 2 2 2019-02-15 2019-09-09 wonook@apache.org wsong0512@gmail.com common/src/main/java/org/apache/nemo/common/ByteBufferInputStream.java 28 2 1508 1433 2 2 2019-06-25 2019-09-08 chohy0555@gmail.com wsong0512@gmail.com ml/nemo_xgboost_optimization.py 264 1 1595 1595 1 1 2019-03-30 2019-03-30 wonook@apache.org wonook@apache.org webui/nuxt.config.js 39 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com webui/plugins/vue2vis.js 3 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com webui/plugins/vue-affix.js 3 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com webui/plugins/element-ui.js 4 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com webui/plugins/event-bus.js 6 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com webui/components/stages/StagesView.vue 142 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/MainContainer.vue 91 3 1701 1273 3 3 2018-12-14 2020-02-15 1418874+skystar-p@users.noreply.github.com jangho@jangho.io webui/components/storage/StorageView.vue 31 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/executors/ExecutorsView.vue 32 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/environment/EnvironmentView.vue 32 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/jobs/JobsView.vue 726 2 1700 1273 2 2 2018-12-15 2020-02-15 wonook@apache.org jangho@jangho.io webui/components/jobs/detail/StageSelect.vue 172 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/jobs/detail/MetricTimeline.vue 126 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/jobs/detail/JobView.vue 272 2 1700 1273 2 2 2018-12-15 2020-02-15 wonook@apache.org jangho@jangho.io webui/components/jobs/detail/DetailTable.vue 49 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/jobs/detail/DAG.vue 662 1 1700 1700 1 1 2018-12-15 2018-12-15 wonook@apache.org wonook@apache.org webui/components/TaskStatistics.vue 91 3 1701 1273 3 3 2018-12-14 2020-02-15 1418874+skystar-p@users.noreply.github.com jangho@jangho.io webui/layouts/default.vue 34 2 1701 1700 2 2 2018-12-14 2018-12-15 1418874+skystar-p@users.noreply.github.com wonook@apache.org webui/assets/constants.js 16 2 1701 1700 2 2 2018-12-14 2018-12-15 1418874+skystar-p@users.noreply.github.com wonook@apache.org webui/pages/index.vue 13 1 1701 1701 1 1 2018-12-14 2018-12-14 1418874+skystar-p@users.noreply.github.com 1418874+skystar-p@users.noreply.github.com conf/src/main/java/org/apache/nemo/conf/DataPlaneConf.java 49 3 1449 1303 3 2 2019-08-23 2020-01-16 chohy0555@gmail.com 43122460+polarcoke2@users.noreply.github.com conf/src/main/java/org/apache/nemo/conf/JobConf.java 161 14 1800 662 14 8 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com client/src/main/java/org/apache/nemo/client/NemoClient.java 21 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io client/src/main/java/org/apache/nemo/client/DriverEndpoint.java 24 4 1800 1234 4 2 2018-09-06 2020-03-25 jangho@jangho.io wonook@apache.org client/src/main/java/org/apache/nemo/client/ClientUtils.java 56 3 1595 725 3 3 2019-03-30 2021-08-16 wonook@apache.org wsong0512@gmail.com client/src/main/java/org/apache/nemo/client/ClientEndpoint.java 76 4 1800 1234 4 2 2018-09-06 2020-03-25 jangho@jangho.io wonook@apache.org client/src/main/java/org/apache/nemo/client/StateTranslator.java 5 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org client/src/main/java/org/apache/nemo/client/beam/NemoRunnerRegistrar.java 26 2 1614 1598 2 2 2019-03-11 2019-03-27 taegeonum@gmail.com wonook@apache.org client/src/main/java/org/apache/nemo/client/beam/NemoRunner.java 37 3 1614 1234 3 2 2019-03-11 2020-03-25 taegeonum@gmail.com wonook@apache.org client/src/main/java/org/apache/nemo/client/beam/NemoPipelineResult.java 65 3 1614 1234 3 2 2019-03-11 2020-03-25 taegeonum@gmail.com wonook@apache.org client/src/main/java/org/apache/nemo/client/beam/BeamStateTranslator.java 21 1 1614 1614 1 1 2019-03-11 2019-03-11 taegeonum@gmail.com taegeonum@gmail.com client/src/main/java/org/apache/nemo/client/DriverRPCServer.java 120 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org client/src/main/java/org/apache/nemo/client/JobLauncher.java 339 23 1800 662 25 15 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com client/src/main/java/org/apache/reef/runtime/yarn/ClassPathBuilder.java 46 3 1753 995 4 3 2018-10-23 2020-11-19 jangho@jangho.io 60352009+jaehwan0214@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/SideInputElement.java 15 3 1724 1598 3 3 2018-11-21 2019-03-27 johnyangk@gmail.com wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/InMemorySideInputReader.java 61 5 1724 1333 5 5 2018-11-21 2019-12-17 johnyangk@gmail.com 48579185+ulgal@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineVisitor.java 28 7 1800 1598 7 5 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.java 135 11 1800 1598 11 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.java 123 10 1751 1598 10 6 2018-10-25 2019-03-27 strayyyyyy@gmail.com wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslator.java 398 23 1800 375 24 10 2018-09-06 2022-08-01 jangho@jangho.io wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/BeamKeyExtractor.java 28 7 1800 1432 7 5 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/NemoPipelineOptions.java 14 4 1800 1709 4 3 2018-09-06 2018-12-06 jangho@jangho.io egjung49@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/PipelineTranslationContext.java 188 8 1739 1027 8 5 2018-11-06 2020-10-18 johnyangk@gmail.com 60352009+jaehwan0214@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamEncoderFactory.java 55 6 1800 1282 6 4 2018-09-06 2020-02-06 jangho@jangho.io 54828276+ske-kr@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.java 37 4 1724 1598 4 3 2018-11-21 2019-03-27 johnyangk@gmail.com wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.java 74 6 1800 1306 6 4 2018-09-06 2020-01-13 jangho@jangho.io 43871098+byungheecha@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.java 33 4 1724 662 4 4 2018-11-21 2021-10-18 johnyangk@gmail.com goehd4551@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.java 56 11 1765 973 12 6 2018-10-11 2020-12-11 taegeonum@gmail.com wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.java 60 4 1738 1298 4 4 2018-11-07 2020-01-21 johnyangk@gmail.com 32813753+sharkmir1@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/DefaultOutputManager.java 22 4 1765 1598 5 4 2018-10-11 2019-03-27 taegeonum@gmail.com wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.java 212 5 1031 375 6 3 2020-10-14 2022-08-01 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.java 25 7 1800 662 7 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.java 58 3 1738 1598 3 3 2018-11-07 2019-03-27 johnyangk@gmail.com wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.java 8 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.java 38 1 1031 1031 1 1 2020-10-14 2020-10-14 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.java 189 13 1757 375 17 8 2018-10-19 2022-08-01 taegeonum@gmail.com wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.java 61 7 1765 662 7 6 2018-10-11 2021-10-18 taegeonum@gmail.com goehd4551@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.java 81 11 1800 662 11 6 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryTimerInternalsFactory.java 49 2 1031 973 2 2 2020-10-14 2020-12-11 60352009+jaehwan0214@users.noreply.github.com wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.java 103 7 1724 973 7 6 2018-11-21 2020-12-11 johnyangk@gmail.com wsong0512@gmail.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/GroupByKeyTransform.java 40 8 1800 1598 8 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/InMemoryStateInternalsFactory.java 23 1 1031 1031 1 1 2020-10-14 2020-10-14 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com compiler/frontend/beam/src/main/java/org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.java 39 1 1031 1031 1 1 2020-10-14 2020-10-14 60352009+jaehwan0214@users.noreply.github.com 60352009+jaehwan0214@users.noreply.github.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/JavaSparkContext.java 22 4 1800 1277 4 3 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkContext.java 35 4 1800 1277 4 3 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaRDD.java 423 1 1277 1277 1 1 2020-02-11 2020-02-11 jeongyoon0807@gmail.com jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/rdd/SparkJavaPairRDD.java 511 1 1277 1277 1 1 2020-02-11 2020-02-11 jeongyoon0807@gmail.com jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkFrontendUtils.java 118 8 1800 1278 8 6 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/core/SparkBroadcast.java 22 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkDatasetBoundedSourceVertex.java 103 7 1800 1278 7 5 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkSourceUtil.java 38 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/source/SparkTextFileBoundedSourceVertex.java 100 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.java 25 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/SparkBroadcastVariables.java 23 3 1800 1709 3 2 2018-09-06 2018-12-06 jangho@jangho.io egjung49@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkDecoderFactory.java 34 5 1800 1278 5 3 2018-09-06 2020-02-10 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/coder/SparkEncoderFactory.java 34 5 1800 1277 5 3 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/FlatMapTransform.java 25 6 1800 662 6 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/HDFSTextFileTransform.java 43 5 1800 1312 6 4 2018-09-06 2020-01-07 jangho@jangho.io 43238893+tyj9327@users.noreply.github.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceByKeyTransform.java 44 5 1800 1344 5 4 2018-09-06 2019-12-06 jangho@jangho.io bdv111@snu.ac.kr compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/CollectTransform.java 26 5 1800 1318 5 4 2018-09-06 2020-01-01 jangho@jangho.io haesoo1108@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapTransform.java 25 6 1800 662 6 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/MapToPairTransform.java 27 6 1800 662 6 5 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/GroupByKeyTransform.java 33 5 1800 1298 5 4 2018-09-06 2020-01-21 jangho@jangho.io 54934934+1207koo@users.noreply.github.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/ReduceTransform.java 56 7 1800 662 7 6 2018-09-06 2021-10-18 jangho@jangho.io goehd4551@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/transform/LocalTextFileTransform.java 38 5 1800 1298 6 4 2018-09-06 2020-01-21 jangho@jangho.io 54934934+1207koo@users.noreply.github.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/NemoSparkUserFacingClass.java 20 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/Dataset.java 656 4 1800 1277 4 3 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/DataFrameReader.java 271 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/frontend/spark/src/main/java/org/apache/nemo/compiler/frontend/spark/sql/SparkSession.java 242 5 1800 1318 5 4 2018-09-06 2020-01-01 jangho@jangho.io haesoo1108@gmail.com compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/PairRDDFunctions.scala 222 2 1800 1750 2 1 2018-09-06 2018-10-26 jangho@jangho.io jangho@jangho.io compiler/frontend/spark/src/main/scala/org/apache/nemo/compiler/frontend/spark/core/rdd/RDD.scala 397 6 1800 1277 6 5 2018-09-06 2020-02-11 jangho@jangho.io jeongyoon0807@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/NemoOptimizer.java 150 8 1800 1250 8 5 2018-09-06 2020-03-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/Optimizer.java 9 5 1800 1598 6 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/Message.java 25 1 1646 1646 1 1 2019-02-07 2019-02-07 johnyangk@gmail.com johnyangk@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/RunTimePass.java 6 2 1646 1598 2 2 2019-02-07 2019-03-27 johnyangk@gmail.com wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/DynamicTaskSizingRuntimePass.java 100 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRunTimePass.java 135 4 1646 1335 4 4 2019-02-07 2019-12-15 johnyangk@gmail.com platina47@naver.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewHandlingUtil.java 54 6 1632 1134 6 6 2019-02-21 2020-07-03 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LargeShuffleReshapingPass.java 23 5 1652 1298 5 4 2019-02-01 2020-01-21 johnyangk@gmail.com 37951125+sanggggg@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SkewReshapingPass.java 47 14 1800 1134 15 10 2018-09-06 2020-07-03 jangho@jangho.io 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/ReshapingPass.java 18 6 1800 1598 6 5 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPass.java 209 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopUnrollingPass.java 43 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingSkewReshapingPass.java 85 7 1632 1134 7 7 2019-02-21 2020-07-03 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPass.java 195 3 1134 973 3 2 2020-07-03 2020-12-11 43122460+polarcoke2@users.noreply.github.com wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopOptimizations.java 214 7 1800 1306 7 6 2018-09-06 2020-01-13 jangho@jangho.io 43871098+byungheecha@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPass.java 129 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/CompositePass.java 40 5 1800 1598 5 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/LargeShuffleCompositePass.java 12 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/SkewCompositePass.java 12 5 1800 1646 5 3 2018-09-06 2019-02-07 jangho@jangho.io johnyangk@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/TransientResourceCompositePass.java 12 4 1800 1417 4 3 2018-09-06 2019-09-24 jangho@jangho.io johnyangk@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/LoopOptimizationCompositePass.java 17 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/DefaultCompositePass.java 18 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/CompileTimePass.java 9 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/SkewAnnotatingPass.java 34 4 1646 1134 4 4 2019-02-07 2020-07-03 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/AnnotatingPass.java 25 3 1800 1598 3 2 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultEdgeEncoderPass.java 22 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LargeShuffleAnnotatingPass.java 32 7 1652 1432 7 4 2019-02-01 2019-09-09 johnyangk@gmail.com wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourcePriorityPass.java 42 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultDataStorePass.java 18 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/UpfrontCloningPass.java 26 6 1800 1298 6 5 2018-09-06 2020-01-21 jangho@jangho.io 37951125+sanggggg@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/XGBoostPass.java 88 2 1595 1397 2 2 2019-03-30 2019-10-14 wonook@apache.org wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/PipeTransferForAllEdgesPass.java 21 6 1746 375 6 4 2018-10-30 2022-08-01 johnyangk@gmail.com wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultDataPersistencePass.java 29 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPass.java 100 7 1800 1376 7 5 2018-09-06 2019-11-04 jangho@jangho.io sanhaleehana@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceLocalityPass.java 16 5 1800 1598 5 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DisaggregationEdgeDataStorePass.java 22 4 1800 1432 4 3 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPass.java 138 8 1800 1291 8 5 2018-09-06 2020-01-28 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DuplicateEdgeGroupSizePass.java 38 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultEdgeDecoderPass.java 22 4 1800 1598 4 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ShuffleEdgePushPass.java 29 5 1800 1432 5 4 2018-09-06 2019-09-09 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/CompressionPass.java 26 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/TransientResourceDataTransferPass.java 43 1 1417 1417 1 1 2019-09-24 2019-09-24 johnyangk@apache.org johnyangk@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSitePass.java 182 8 1800 1389 8 6 2018-09-06 2019-10-22 jangho@jangho.io jangho@jangho.io compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/LambdaPass.java 15 3 1526 1277 3 3 2019-06-07 2020-02-11 alapha23@gmail.com jeongyoon0807@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/ResourceSlotPass.java 16 5 1800 1598 5 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/Annotates.java 9 3 1800 1709 3 2 2018-09-06 2018-12-06 jangho@jangho.io egjung49@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/AggressiveSpeculativeCloningPass.java 17 3 1800 1652 3 2 2018-09-06 2019-02-01 jangho@jangho.io johnyangk@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/pass/compiletime/Requires.java 9 3 1800 1709 3 2 2018-09-06 2018-12-06 jangho@jangho.io egjung49@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/OptimizerUtils.java 43 1 1595 1595 1 1 2019-03-30 2019-03-30 wonook@apache.org wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/BasicPullPolicy.java 23 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DisaggregationPolicy.java 25 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/StreamingPolicy.java 22 3 1709 1646 3 2 2018-12-06 2019-02-07 taegeonum@gmail.com johnyangk@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DynamicTaskSizingPolicy.java 34 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DefaultPolicyWithSeparatePass.java 34 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/TransientResourcePolicy.java 25 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DefaultPolicy.java 21 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/SamplingLargeShuffleSkewPolicy.java 30 2 1632 1598 2 2 2019-02-21 2019-03-27 johnyangk@gmail.com wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/BasicPushPolicy.java 25 4 1800 1646 4 2 2018-09-06 2019-02-07 jangho@jangho.io johnyangk@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/DataSkewPolicy.java 28 6 1800 1598 6 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/LambdaPolicy.java 22 1 1526 1526 1 1 2019-06-07 2019-06-07 alapha23@gmail.com alapha23@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/LargeShufflePolicy.java 25 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/XGBoostPolicy.java 23 1 1595 1595 1 1 2019-03-30 2019-03-30 wonook@apache.org wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyImpl.java 128 8 1800 1282 8 5 2018-09-06 2020-02-06 jangho@jangho.io xiangmu97@naver.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/Policy.java 8 6 1800 1433 7 4 2018-09-06 2019-09-08 jangho@jangho.io wsong0512@gmail.com compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/PolicyBuilder.java 78 6 1800 1598 6 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/optimizer/src/main/java/org/apache/nemo/compiler/optimizer/policy/ConditionalLargeShufflePolicy.java 31 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/backend/src/main/java/org/apache/nemo/compiler/backend/Backend.java 8 5 1800 1598 5 3 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoBackend.java 21 6 1800 1598 6 4 2018-09-06 2019-03-27 jangho@jangho.io wonook@apache.org compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/SkewProphet.java 25 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/ParallelismProphet.java 93 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/prophet/Prophet.java 5 1 990 990 1 1 2020-11-24 2020-11-24 43122460+polarcoke2@users.noreply.github.com 43122460+polarcoke2@users.noreply.github.com compiler/backend/src/main/java/org/apache/nemo/compiler/backend/nemo/NemoPlanRewriter.java 114 6 1646 990 6 3 2019-02-07 2020-11-24 johnyangk@gmail.com 43122460+polarcoke2@users.noreply.github.com