public class ApplicationMaster extends Object implements 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<ContainerId,IgniteContainer> |
getContainers()
Deprecated.
|
float |
getProgress() |
void |
init() |
static void |
main(String[] args) |
void |
onContainersAllocated(List<Container> conts) |
void |
onContainersCompleted(List<ContainerStatus> statuses) |
void |
onError(Throwable t) |
void |
onNodesUpdated(List<NodeReport> updated) |
void |
onShutdownRequest() |
void |
run()
Runs application master.
|
void |
setFs(FileSystem fs)
Sets file system.
|
void |
setNmClient(NMClient nmClient)
Sets NMClient.
|
void |
setRmClient(AMRMClientAsync<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.Exceptionpublic void onContainersAllocated(List<Container> conts)
onContainersAllocated in interface AMRMClientAsync.CallbackHandlerpublic void onContainersCompleted(List<ContainerStatus> statuses)
onContainersCompleted in interface AMRMClientAsync.CallbackHandlerpublic void onNodesUpdated(List<NodeReport> updated)
onNodesUpdated in interface AMRMClientAsync.CallbackHandlerpublic void onShutdownRequest()
onShutdownRequest in interface AMRMClientAsync.CallbackHandlerpublic void onError(Throwable t)
onError in interface AMRMClientAsync.CallbackHandlerpublic float getProgress()
getProgress in interface AMRMClientAsync.CallbackHandlerpublic static void main(String[] args) throws Exception
args - Args.Exception - If failed.public void init()
throws IOException
IOExceptionpublic void setNmClient(NMClient nmClient)
nmClient - NMClient.public void setRmClient(AMRMClientAsync<AMRMClient.ContainerRequest> rmClient)
rmClient - AMRMClientAsync.public void setSchedulerTimeout(long schedulerTimeout)
schedulerTimeout - Scheduler timeout.public void setFs(FileSystem fs)
fs - File system.@Deprecated public Map<ContainerId,IgniteContainer> getContainers()
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016