Path	Lines of Code
tez-dag/findbugs-exclude.xml	10
tez-dag/src/main/java/org/apache/tez/dag/api/client/DAGClientHandler.java	106
tez-dag/src/main/java/org/apache/tez/dag/api/client/DAGClientServer.java	92
tez-dag/src/main/java/org/apache/tez/dag/api/client/DAGStatusBuilder.java	63
tez-dag/src/main/java/org/apache/tez/dag/api/client/ProgressBuilder.java	29
tez-dag/src/main/java/org/apache/tez/dag/api/client/VertexStatusBuilder.java	63
tez-dag/src/main/java/org/apache/tez/dag/api/client/rpc/DAGClientAMProtocolBlockingPBServerImpl.java	142
tez-dag/src/main/java/org/apache/tez/dag/api/oldrecords/AMInfo.java	17
tez-dag/src/main/java/org/apache/tez/dag/api/oldrecords/TaskAttemptReport.java	34
tez-dag/src/main/java/org/apache/tez/dag/api/oldrecords/TaskAttemptState.java	9
tez-dag/src/main/java/org/apache/tez/dag/api/oldrecords/TaskReport.java	17
tez-dag/src/main/java/org/apache/tez/dag/api/oldrecords/TaskState.java	4
tez-dag/src/main/java/org/apache/tez/dag/app/AppContext.java	44
tez-dag/src/main/java/org/apache/tez/dag/app/ClusterInfo.java	23
tez-dag/src/main/java/org/apache/tez/dag/app/ContainerContext.java	128
tez-dag/src/main/java/org/apache/tez/dag/app/ContainerHeartbeatHandler.java	31
tez-dag/src/main/java/org/apache/tez/dag/app/ControlledClock.java	22
tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMaster.java	1571
tez-dag/src/main/java/org/apache/tez/dag/app/DAGAppMasterState.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/HeartbeatHandlerBase.java	116
tez-dag/src/main/java/org/apache/tez/dag/app/RecoveryParser.java	840
tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListener.java	11
tez-dag/src/main/java/org/apache/tez/dag/app/TaskAttemptListenerImpTezDag.java	362
tez-dag/src/main/java/org/apache/tez/dag/app/TaskHeartbeatHandler.java	32
tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAG.java	43
tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGReport.java	38
tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGScheduler.java	9
tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGState.java	11
tez-dag/src/main/java/org/apache/tez/dag/app/dag/DAGTerminationCause.java	10
tez-dag/src/main/java/org/apache/tez/dag/app/dag/RootInputInitializerManager.java	209
tez-dag/src/main/java/org/apache/tez/dag/app/dag/Task.java	29
tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskAttempt.java	57
tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskAttemptStateInternal.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskStateInternal.java	4
tez-dag/src/main/java/org/apache/tez/dag/app/dag/TaskTerminationCause.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/dag/Vertex.java	82
tez-dag/src/main/java/org/apache/tez/dag/app/dag/VertexState.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/VertexTerminationCause.java	11
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGAppMasterEvent.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGAppMasterEventDAGFinished.java	19
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGAppMasterEventType.java	6
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventCounterUpdate.java	31
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventDiagnosticsUpdate.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventRecoverEvent.java	27
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventSchedulerUpdate.java	23
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventSchedulerUpdateTAAssigned.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventStartDag.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventType.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventVertexCompleted.java	31
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DAGEventVertexReRunning.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/DiagnosableEvent.java	4
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventAttemptFailed.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventContainerTerminated.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventContainerTerminatedBySystem.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventContainerTerminating.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventDiagnosticsUpdate.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventFailRequest.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventKillRequest.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventNodeFailed.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventOutputFailed.java	19
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventSchedule.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStartedRemotely.java	21
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventStatusUpdate.java	52
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskAttemptEventType.java	20
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventAddTezEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventRecoverTask.java	25
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventTAUpdate.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventTermination.java	19
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/TaskEventType.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventNullEdgeInitialized.java	19
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventOneToOneSourceSplit.java	25
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventRecoverVertex.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventRootInputFailed.java	17
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventRootInputInitialized.java	24
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventRouteEvent.java	23
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventSourceTaskAttemptCompleted.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventSourceVertexRecovered.java	34
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventSourceVertexStarted.java	19
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskAttemptCompleted.java	20
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskCompleted.java	18
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTaskReschedule.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventTermination.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/VertexEventType.java	21
tez-dag/src/main/java/org/apache/tez/dag/app/dag/event/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/BroadcastEdgeManager.java	51
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGImpl.java	1504
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGSchedulerMRR.java	239
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/DAGSchedulerNaturalOrder.java	50
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/Edge.java	342
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/ImmediateStartVertexManager.java	38
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/OneToOneEdgeManager.java	43
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/OutputCommitterContextImpl.java	63
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/RootInputLeafOutputDescriptor.java	22
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/RootInputVertexManager.java	85
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/ScatterGatherEdgeManager.java	44
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImpl.java	1222
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskAttemptImplHelpers.java	36
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskImpl.java	1132
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TaskReportImpl.java	63
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/TezRootInputInitializerContextImpl.java	63
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexImpl.java	3184
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexManager.java	231
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/VertexStats.java	128
tez-dag/src/main/java/org/apache/tez/dag/app/dag/impl/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/dag/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncher.java	6
tez-dag/src/main/java/org/apache/tez/dag/app/launcher/ContainerLauncherImpl.java	300
tez-dag/src/main/java/org/apache/tez/dag/app/launcher/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEvent.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventDeallocateContainer.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventNodeBlacklistUpdate.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTAEnded.java	29
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventTALaunchRequest.java	52
tez-dag/src/main/java/org/apache/tez/dag/app/rm/AMSchedulerEventType.java	10
tez-dag/src/main/java/org/apache/tez/dag/app/rm/ContainerAllocator.java	4
tez-dag/src/main/java/org/apache/tez/dag/app/rm/LocalTaskSchedulerService.java	268
tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorEvent.java	67
tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorEventType.java	5
tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorLaunchRequestEvent.java	20
tez-dag/src/main/java/org/apache/tez/dag/app/rm/NMCommunicatorStopRequestEvent.java	11
tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerAppCallbackWrapper.java	227
tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerEventHandler.java	425
tez-dag/src/main/java/org/apache/tez/dag/app/rm/TaskSchedulerService.java	65
tez-dag/src/main/java/org/apache/tez/dag/app/rm/TezAMRMClientAsync.java	119
tez-dag/src/main/java/org/apache/tez/dag/app/rm/YarnTaskSchedulerService.java	1618
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainer.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventAssignTA.java	33
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventCompleted.java	25
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunchFailed.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunchRequest.java	24
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventLaunched.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventNodeFailed.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventStopFailed.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventStopRequest.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventTASucceeded.java	14
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerEventType.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerHelpers.java	148
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerImpl.java	975
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerMap.java	53
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerState.java	10
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/AMContainerTask.java	35
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/ContainerContextMatcher.java	43
tez-dag/src/main/java/org/apache/tez/dag/app/rm/container/ContainerSignatureMatcher.java	9
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNode.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEvent.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventContainerAllocated.java	13
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventNodeCountUpdated.java	11
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventStateChanged.java	15
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventTaskAttemptEnded.java	28
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventTaskAttemptSucceeded.java	20
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeEventType.java	12
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeImpl.java	368
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeMap.java	163
tez-dag/src/main/java/org/apache/tez/dag/app/rm/node/AMNodeState.java	7
tez-dag/src/main/java/org/apache/tez/dag/app/rm/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/TezAMPolicyProvider.java	25
tez-dag/src/main/java/org/apache/tez/dag/app/security/authorize/package-info.java	3
tez-dag/src/main/java/org/apache/tez/dag/history/DAGHistoryEvent.java	20
tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEvent.java	11
tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventHandler.java	87
tez-dag/src/main/java/org/apache/tez/dag/history/HistoryEventType.java	24
tez-dag/src/main/java/org/apache/tez/dag/history/SummaryEvent.java	9
tez-dag/src/main/java/org/apache/tez/dag/history/events/AMLaunchedEvent.java	79
tez-dag/src/main/java/org/apache/tez/dag/history/events/AMStartedEvent.java	71
tez-dag/src/main/java/org/apache/tez/dag/history/events/ContainerLaunchedEvent.java	76
tez-dag/src/main/java/org/apache/tez/dag/history/events/ContainerStoppedEvent.java	85
tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGCommitStartedEvent.java	74
tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGFinishedEvent.java	149
tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGInitializedEvent.java	75
tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGStartedEvent.java	74
tez-dag/src/main/java/org/apache/tez/dag/history/events/DAGSubmittedEvent.java	135
tez-dag/src/main/java/org/apache/tez/dag/history/events/TaskAttemptFinishedEvent.java	122
tez-dag/src/main/java/org/apache/tez/dag/history/events/TaskAttemptStartedEvent.java	100
tez-dag/src/main/java/org/apache/tez/dag/history/events/TaskFinishedEvent.java	131
tez-dag/src/main/java/org/apache/tez/dag/history/events/TaskStartedEvent.java	75
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexCommitStartedEvent.java	81
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexDataMovementEventsGeneratedEvent.java	175
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexFinishedEvent.java	175
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexGroupCommitFinishedEvent.java	89
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexGroupCommitStartedEvent.java	89
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexInitializedEvent.java	143
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexParallelismUpdatedEvent.java	154
tez-dag/src/main/java/org/apache/tez/dag/history/events/VertexStartedEvent.java	72
tez-dag/src/main/java/org/apache/tez/dag/history/logging/EntityTypes.java	9
tez-dag/src/main/java/org/apache/tez/dag/history/logging/HistoryLoggingService.java	14
tez-dag/src/main/java/org/apache/tez/dag/history/logging/impl/HistoryEventJsonConversion.java	481
tez-dag/src/main/java/org/apache/tez/dag/history/logging/impl/SimpleHistoryLoggingService.java	138
tez-dag/src/main/java/org/apache/tez/dag/history/recovery/RecoveryService.java	358
tez-dag/src/main/java/org/apache/tez/dag/history/utils/ATSConstants.java	44
tez-dag/src/main/java/org/apache/tez/dag/history/utils/DAGUtils.java	279
tez-dag/src/main/java/org/apache/tez/dag/utils/EnvironmentUpdateUtils.java	39
tez-dag/src/main/java/org/apache/tez/dag/utils/Graph.java	207
tez-dag/src/main/java/org/apache/tez/dag/utils/JavaProfilerOptions.java	101
tez-dag/src/main/java/org/apache/tez/dag/utils/ProtoUtils.java	13
tez-dag/src/main/java/org/apache/tez/dag/utils/RelocalizationUtils.java	65
tez-dag/src/main/java/org/apache/tez/dag/utils/TezBuilderUtils.java	28
tez-dag/src/main/java/org/apache/tez/dag/utils/TezRuntimeChildJVM.java	58
tez-dag/src/main/java/org/apache/tez/runtime/task/ContainerReporter.java	52
tez-dag/src/main/java/org/apache/tez/runtime/task/ErrorReporter.java	5
tez-dag/src/main/java/org/apache/tez/runtime/task/TaskReporter.java	254
tez-dag/src/main/java/org/apache/tez/runtime/task/TezChild.java	279
tez-dag/src/main/java/org/apache/tez/runtime/task/TezTaskRunner.java	290
tez-dag/src/main/proto/HistoryEvents.proto	172