Path Lines of Code client/src/test/java/org/apache/nemo/client/ClientDriverRPCTest.java 56 client/src/test/java/org/apache/nemo/client/ClientEndpointTest.java 51 common/src/main/java/org/apache/nemo/common/test/ArgBuilder.java 48 common/src/main/java/org/apache/nemo/common/test/EmptyComponents.java 187 common/src/main/java/org/apache/nemo/common/test/ExampleTestArgs.java 13 common/src/main/java/org/apache/nemo/common/test/ExampleTestUtil.java 107 common/src/test/java/org/apache/nemo/common/DAGTest.java 124 common/src/test/java/org/apache/nemo/common/PairTest.java 25 common/src/test/java/org/apache/nemo/common/StateMachineTest.java 42 common/src/test/java/org/apache/nemo/common/UtilTest.java 25 common/src/test/java/org/apache/nemo/common/coder/CoderFactoryTest.java 34 common/src/test/java/org/apache/nemo/common/ir/IRDAGTest.java 493 common/src/test/java/org/apache/nemo/common/ir/LoopVertexTest.java 70 common/src/test/java/org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMapTest.java 88 compiler/backend/src/test/java/org/apache/nemo/compiler/backend/nemo/NemoBackendTest.java 47 compiler/optimizer/src/test/java/org/apache/nemo/compiler/optimizer/policy/PolicyBuilderTest.java 36 compiler/optimizer/src/test/java/org/apache/nemo/compiler/optimizer/policy/PolicyImplTest.java 76 compiler/test/pom.xml 62 compiler/test/src/main/java/org/apache/nemo/compiler/CompilerTestUtil.java 98 compiler/test/src/main/java/org/apache/nemo/compiler/optimizer/policy/TestPolicy.java 31 compiler/test/src/test/java/org/apache/nemo/compiler/backend/nemo/DAGConverterTest.java 124 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/BeamFrontendALSTest.java 28 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/BeamFrontendMLRTest.java 28 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/transform/CombineFnTest.java 94 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransformTest.java 90 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/transform/DoFnTransformTest.java 297 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/transform/GBKTransformTest.java 419 compiler/test/src/test/java/org/apache/nemo/compiler/frontend/beam/transform/TestOutputCollector.java 44 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultEdgeCoderPassTest.java 58 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultParallelismPassTest.java 42 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/annotating/DefaultScheduleGroupPassTest.java 156 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/DisaggregationPassTest.java 34 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/LargeShuffleCompositePassTest.java 68 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/SkewCompositePassTest.java 68 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/composite/TransientResourceCompositePassTest.java 37 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/CommonSubexpressionEliminationPassTest.java 56 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopExtractionPassTest.java 24 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopFusionPassTest.java 109 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopInvariantCodeMotionALSInefficientTest.java 28 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopInvariantCodeMotionPassTest.java 83 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/LoopUnrollingPassTest.java 41 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/compiletime/reshaping/SamplingTaskSizingPassTest.java 35 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/runtime/DynamicTaskSizingRuntimePassTest.java 48 compiler/test/src/test/java/org/apache/nemo/compiler/optimizer/pass/runtime/SkewRuntimePassTest.java 54 runtime/common/src/test/java/org/apache/nemo/runtime/common/message/local/LocalMessageTest.java 125 runtime/common/src/test/java/org/apache/nemo/runtime/common/metric/MetricUtilsTest.java 114 runtime/common/src/test/java/org/apache/nemo/runtime/common/plan/PhysicalPlanGeneratorTest.java 48 runtime/common/src/test/java/org/apache/nemo/runtime/common/plan/StagePartitionerTest.java 124 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/MetricFlushTest.java 88 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/TestUtil.java 15 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/TransformContextImplTest.java 31 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/BlockStoreTest.java 461 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/BlockTest.java 81 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/BlockTransferThrottlerTest.java 48 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/DirectByteBufferOutputStreamTest.java 84 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/MemoryChunkTest.java 75 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/data/MemoryPoolAssignerTest.java 67 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/datatransfer/DataTransferTest.java 413 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/datatransfer/InputWatermarkManagerTest.java 47 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/task/ParentTaskDataFetcherTest.java 119 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/task/TaskExecutorTest.java 651 runtime/executor/src/test/java/org/apache/nemo/runtime/executor/transfer/LocalTransferContextTest.java 72 runtime/master/src/test/java/org/apache/nemo/runtime/master/BlockManagerMasterTest.java 101 runtime/master/src/test/java/org/apache/nemo/runtime/master/ContainerManagerTest.java 132 runtime/master/src/test/java/org/apache/nemo/runtime/master/MetricStoreTest.java 25 runtime/master/src/test/java/org/apache/nemo/runtime/master/PlanStateManagerTest.java 78 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/AntiAffinitySchedulingConstraintTest.java 50 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/BatchSchedulerTest.java 125 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/ContainerTypeAwareSchedulingConstraintTest.java 51 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/FreeSlotSchedulingConstraintTest.java 56 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/LocalitySchedulingConstraintTest.java 126 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/MinOccupancyFirstSchedulingPolicyTest.java 44 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/PendingTaskCollectionPointerTest.java 51 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/SchedulerTestUtil.java 58 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/SchedulingConstraintnRegistryTest.java 38 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/SimulationSchedulerTest.java 71 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/StreamingSchedulerTest.java 56 runtime/master/src/test/java/org/apache/nemo/runtime/master/scheduler/TaskRetryTest.java 186 runtime/test/pom.xml 24 runtime/test/src/main/java/org/apache/nemo/runtime/common/plan/TestPlanGenerator.java 120 webui/test/DetailTable.test.js 38 webui/test/JobView.test.js 131 webui/test/JobsView.test.js 106 webui/test/MetricTimeline.test.js 84 webui/test/StageSelect.test.js 68 webui/test/setup.js 4