public class ApplicationImpl extends Object implements Application
Modifier and Type | Class and Description |
---|---|
static class |
ApplicationImpl.FlowContext
Data object that encapsulates the flow context for the application purpose.
|
Constructor and 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) |
Modifier and Type | Method and 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() |
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)
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)
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)
public String getUser()
getUser
in interface Application
public org.apache.hadoop.yarn.api.records.ApplicationId getAppId()
getAppId
in interface Application
public ApplicationState getApplicationState()
getApplicationState
in interface Application
public Map<org.apache.hadoop.yarn.api.records.ContainerId,Container> getContainers()
getContainers
in interface Application
public void handle(ApplicationEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<ApplicationEvent>
public org.apache.hadoop.yarn.api.records.LogAggregationContext getLogAggregationContext()
public String getFlowName()
getFlowName
in interface Application
public String getFlowVersion()
getFlowVersion
in interface Application
public long getFlowRunId()
getFlowRunId
in interface Application
public void setFlowContext(ApplicationImpl.FlowContext fc)
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.