Package org.apache.hadoop.yarn.server.nodemanager.containermanager.application

Class ApplicationImpl

java.lang.Object

org.apache.hadoop.yarn.server.nodemanager.containermanager.application.ApplicationImpl

All Implemented Interfaces:

org.apache.hadoop.yarn.event.EventHandler<ApplicationEvent>, Application

public class ApplicationImpl
extends Object
implements Application

The state machine for the representation of an Application within the NodeManager.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ApplicationImpl.FlowContext	Data object that encapsulates the flow context for the application purpose.

Constructor Summary

Constructors

Constructor	Description
ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, String user, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.Credentials credentials, Context context)
ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, String user, ApplicationImpl.FlowContext flowContext, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.Credentials credentials, Context context)
ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher, String user, ApplicationImpl.FlowContext flowContext, org.apache.hadoop.yarn.api.records.ApplicationId appId, org.apache.hadoop.security.Credentials credentials, Context context, long recoveredLogInitedTime)

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.yarn.api.records.ApplicationId	getAppId()
ApplicationState	getApplicationState()
Map<org.apache.hadoop.yarn.api.records.ContainerId,Container>	getContainers()
String	getFlowName()
long	getFlowRunId()
String	getFlowVersion()
org.apache.hadoop.yarn.api.records.LogAggregationContext	getLogAggregationContext()
String	getUser()
void	handle(ApplicationEvent event)
void	setFlowContext(ApplicationImpl.FlowContext fc)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ApplicationImpl

public ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 String user,
 org.apache.hadoop.yarn.api.records.ApplicationId appId,
 org.apache.hadoop.security.Credentials credentials,
 Context context)

ApplicationImpl

public ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 String user,
 ApplicationImpl.FlowContext flowContext,
 org.apache.hadoop.yarn.api.records.ApplicationId appId,
 org.apache.hadoop.security.Credentials credentials,
 Context context,
 long recoveredLogInitedTime)

ApplicationImpl

public ApplicationImpl(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 String user,
 ApplicationImpl.FlowContext flowContext,
 org.apache.hadoop.yarn.api.records.ApplicationId appId,
 org.apache.hadoop.security.Credentials credentials,
 Context context)

Method Details

getUser

public String getUser()

Specified by:

getUser in interface Application

getAppId

public org.apache.hadoop.yarn.api.records.ApplicationId getAppId()

Specified by:

getAppId in interface Application

getApplicationState

public ApplicationState getApplicationState()

Specified by:

getApplicationState in interface Application

getContainers

public Map<org.apache.hadoop.yarn.api.records.ContainerId,Container> getContainers()

Specified by:

getContainers in interface Application

handle

public void handle(ApplicationEvent event)

Specified by:

handle in interface org.apache.hadoop.yarn.event.EventHandler<ApplicationEvent>

toString

public String toString()

Overrides:

toString in class Object

getLogAggregationContext

@VisibleForTesting
public org.apache.hadoop.yarn.api.records.LogAggregationContext getLogAggregationContext()

getFlowName

public String getFlowName()

Specified by:

getFlowName in interface Application

getFlowVersion

public String getFlowVersion()

Specified by:

getFlowVersion in interface Application

getFlowRunId

public long getFlowRunId()

Specified by:

getFlowRunId in interface Application

setFlowContext

public void setFlowContext(ApplicationImpl.FlowContext fc)