public interface ApplicationMasterServiceProcessor
Modifier and Type | Method and Description |
---|---|
void |
allocate(ApplicationAttemptId appAttemptId,
AllocateRequest request,
AllocateResponse response)
Allocate call.
|
void |
finishApplicationMaster(ApplicationAttemptId applicationAttemptId,
FinishApplicationMasterRequest request,
FinishApplicationMasterResponse response)
Finish AM.
|
void |
init(ApplicationMasterServiceContext amsContext,
ApplicationMasterServiceProcessor nextProcessor)
Initialize with and ApplicationMasterService Context as well as the
next processor in the chain.
|
void |
registerApplicationMaster(ApplicationAttemptId applicationAttemptId,
RegisterApplicationMasterRequest request,
RegisterApplicationMasterResponse response)
Register AM attempt.
|
void init(ApplicationMasterServiceContext amsContext, ApplicationMasterServiceProcessor nextProcessor)
amsContext
- AMSContext.nextProcessor
- next ApplicationMasterServiceProcessorvoid registerApplicationMaster(ApplicationAttemptId applicationAttemptId, RegisterApplicationMasterRequest request, RegisterApplicationMasterResponse response) throws IOException, YarnException
applicationAttemptId
- applicationAttemptId.request
- Register Request.response
- Register Response.IOException
- IOException.YarnException
- in critical situation where invalid
profiles/resources are added.void allocate(ApplicationAttemptId appAttemptId, AllocateRequest request, AllocateResponse response) throws YarnException
appAttemptId
- appAttemptId.request
- Allocate Request.response
- Allocate Response.YarnException
- YarnException.void finishApplicationMaster(ApplicationAttemptId applicationAttemptId, FinishApplicationMasterRequest request, FinishApplicationMasterResponse response)
applicationAttemptId
- applicationAttemptId.request
- Finish AM Request.response
- Finish AM Response.Copyright © 2008–2021 Apache Software Foundation. All rights reserved.