Added Methods |
void addSchedulingRequests(Collection )
|
Add a Collection of SchedulingRequests. |
AMRMClientAsync createAMRMClientAsync(int, AbstractCallbackHandler)
|
Create a new instance of AMRMClientAsync. |
AMRMClientAsync createAMRMClientAsync(AMRMClient, int, AbstractCallbackHandler)
|
Create a new instance of AMRMClientAsync. |
Collection getMatchingRequests(long )
|
Returns all matching ContainerRequests that match the given AllocationRequestId. |
List getMatchingRequests(Priority, String, ExecutionType, Resource)
|
Returns all matching ContainerRequests that match the given Priority ResourceName ExecutionType and Capability. |
TimelineV2Client getRegisteredTimelineV2Client()
|
Get registered timeline client. |
RegisterApplicationMasterResponse registerApplicationMaster(String, int, String, Map)
|
Register the application master. |
void registerTimelineV2Client(TimelineV2Client )
|
Register TimelineClient to AMRMClient. |
void requestContainerResourceChange(Container, Resource)
|
Request container resource change before calling allocate . |
void requestContainerUpdate(Container, UpdateContainerRequest)
|
Request a container update before calling allocate . |
void updateTrackingUrl(String )
|
Update application's tracking url on next heartbeat. |
void waitFor(Supplier )
|
Wait for check to return true for each 1000 ms. |
void waitFor(Supplier, int)
|
Wait for check to return true for each checkEveryMillis ms. |
void waitFor(Supplier, int, int)
|
Wait for check to return true for each checkEveryMillis ms. |