Package org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities

Class ActivitiesLogger.APP

java.lang.Object

org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities.ActivitiesLogger.APP

Enclosing class:

ActivitiesLogger

public static class ActivitiesLogger.APP
extends Object

Methods for recording activities from an app

Constructor Summary

Constructors

Constructor	Description
APP()

Method Summary

Modifier and Type	Method	Description
static void	finishAllocatedAppAllocationRecording(ActivitiesManager activitiesManager, org.apache.hadoop.yarn.api.records.ApplicationId applicationId, org.apache.hadoop.yarn.api.records.ContainerId containerId, ActivityState containerState, String diagnostic)
static void	finishSkippedAppAllocationRecording(ActivitiesManager activitiesManager, org.apache.hadoop.yarn.api.records.ApplicationId applicationId, ActivityState containerState, String diagnostic)
static void	recordAppActivityWithAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, RMContainer updatedContainer, ActivityState activityState)
static void	recordAppActivityWithoutAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey, String diagnostic, ActivityState appState, ActivityLevel level)
static void	recordRejectedAppActivityFromLeafQueue(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.api.records.Priority priority, String diagnostic)
static void	recordSkippedAppActivityWithoutAllocation(ActivitiesManager activitiesManager, SchedulerNode node, SchedulerApplicationAttempt application, org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey requestKey, String diagnostic, ActivityLevel level)
static void	startAppAllocationRecording(ActivitiesManager activitiesManager, FiCaSchedulerNode node, long currentTime, SchedulerApplicationAttempt application)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

APP

public APP()

Method Details

recordSkippedAppActivityWithoutAllocation

public static void recordSkippedAppActivityWithoutAllocation(ActivitiesManager activitiesManager,
 SchedulerNode node,
 SchedulerApplicationAttempt application,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey requestKey,
 String diagnostic,
 ActivityLevel level)

recordRejectedAppActivityFromLeafQueue

public static void recordRejectedAppActivityFromLeafQueue(ActivitiesManager activitiesManager,
 SchedulerNode node,
 SchedulerApplicationAttempt application,
 org.apache.hadoop.yarn.api.records.Priority priority,
 String diagnostic)

recordAppActivityWithoutAllocation

public static void recordAppActivityWithoutAllocation(ActivitiesManager activitiesManager,
 SchedulerNode node,
 SchedulerApplicationAttempt application,
 org.apache.hadoop.yarn.server.scheduler.SchedulerRequestKey schedulerKey,
 String diagnostic,
 ActivityState appState,
 ActivityLevel level)

recordAppActivityWithAllocation

public static void recordAppActivityWithAllocation(ActivitiesManager activitiesManager,
 SchedulerNode node,
 SchedulerApplicationAttempt application,
 RMContainer updatedContainer,
 ActivityState activityState)

startAppAllocationRecording

public static void startAppAllocationRecording(ActivitiesManager activitiesManager,
 FiCaSchedulerNode node,
 long currentTime,
 SchedulerApplicationAttempt application)

finishAllocatedAppAllocationRecording

public static void finishAllocatedAppAllocationRecording(ActivitiesManager activitiesManager,
 org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
 org.apache.hadoop.yarn.api.records.ContainerId containerId,
 ActivityState containerState,
 String diagnostic)

finishSkippedAppAllocationRecording

public static void finishSkippedAppAllocationRecording(ActivitiesManager activitiesManager,
 org.apache.hadoop.yarn.api.records.ApplicationId applicationId,
 ActivityState containerState,
 String diagnostic)