public class ApplicationMaster extends Object implements org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_PORT
Default port range.
|
static String |
DELIM
Delimiter char.
|
static Logger |
log |
Constructor and Description |
---|
ApplicationMaster(String ignitePath,
ClusterProperties props) |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.ContainerId,IgniteContainer> |
getContainers()
Deprecated.
|
float |
getProgress() |
void |
init() |
static void |
main(String[] args) |
void |
onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> conts) |
void |
onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> statuses) |
void |
onError(Throwable t) |
void |
onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> updated) |
void |
onShutdownRequest() |
void |
run()
Runs application master.
|
void |
setFs(org.apache.hadoop.fs.FileSystem fs)
Sets file system.
|
void |
setNmClient(org.apache.hadoop.yarn.client.api.NMClient nmClient)
Sets NMClient.
|
void |
setRmClient(org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest> rmClient)
Sets RMClient
|
void |
setSchedulerTimeout(long schedulerTimeout)
Sets scheduler timeout.
|
public static final Logger log
public static final String DEFAULT_PORT
public static final String DELIM
public ApplicationMaster(String ignitePath, ClusterProperties props) throws Exception
ignitePath
- Hdfs path to ignite.props
- Cluster properties.Exception
public void onContainersAllocated(List<org.apache.hadoop.yarn.api.records.Container> conts)
onContainersAllocated
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onContainersCompleted(List<org.apache.hadoop.yarn.api.records.ContainerStatus> statuses)
onContainersCompleted
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onNodesUpdated(List<org.apache.hadoop.yarn.api.records.NodeReport> updated)
onNodesUpdated
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onShutdownRequest()
onShutdownRequest
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public void onError(Throwable t)
onError
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public float getProgress()
getProgress
in interface org.apache.hadoop.yarn.client.api.async.AMRMClientAsync.CallbackHandler
public static void main(String[] args) throws Exception
args
- Args.Exception
- If failed.public void init() throws IOException
IOException
public void setNmClient(org.apache.hadoop.yarn.client.api.NMClient nmClient)
nmClient
- NMClient.public void setRmClient(org.apache.hadoop.yarn.client.api.async.AMRMClientAsync<org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest> rmClient)
rmClient
- AMRMClientAsync.public void setSchedulerTimeout(long schedulerTimeout)
schedulerTimeout
- Scheduler timeout.public void setFs(org.apache.hadoop.fs.FileSystem fs)
fs
- File system.@Deprecated public Map<org.apache.hadoop.yarn.api.records.ContainerId,IgniteContainer> getContainers()
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024