|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.yarn.support.LifecycleObjectSupport
org.springframework.yarn.integration.support.IntegrationObjectSupport
org.springframework.yarn.integration.IntegrationAppmasterServiceClient<MindRpcMessageHolder>
org.springframework.yarn.integration.ip.mind.MindAppmasterServiceClient
public abstract class MindAppmasterServiceClient
Implementation of Appmaster service client extending
IntegrationAppmasterServiceClient.
| Constructor Summary | |
|---|---|
MindAppmasterServiceClient()
|
|
| Method Summary | |
|---|---|
BaseResponseObject |
doMindRequest(BaseObject request)
|
protected abstract BaseResponseObject |
getBaseResponseObject(RpcMessage<?> rpcMessage)
This method is called from doMindRequest(BaseObject) to convert
the response content back to mind BaseResponseObject. |
MindRpcMessageHolder |
getPayload(RpcMessage<?> message)
This method is called from IntegrationAppmasterServiceClient.get(RpcMessage) to
resolve the actual payload sent to Sprint Int Tcp channel. |
| Methods inherited from class org.springframework.yarn.integration.IntegrationAppmasterServiceClient |
|---|
get, setRequestChannel, setResponseChannel |
| Methods inherited from class org.springframework.yarn.integration.support.IntegrationObjectSupport |
|---|
getConversionService, setConversionService |
| Methods inherited from class org.springframework.yarn.support.LifecycleObjectSupport |
|---|
afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, onInit, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Methods inherited from interface org.springframework.yarn.client.AppmasterScOperations |
|---|
get |
| Constructor Detail |
|---|
public MindAppmasterServiceClient()
| Method Detail |
|---|
public BaseResponseObject doMindRequest(BaseObject request)
doMindRequest in interface AppmasterMindScOperationsprotected abstract BaseResponseObject getBaseResponseObject(RpcMessage<?> rpcMessage)
doMindRequest(BaseObject) to convert
the response content back to mind BaseResponseObject. This class
itself can't have enough knowledge to do the conversion so process
is left to implementor.
rpcMessage - the rpc message
BaseResponseObject build from a RpcMessagepublic MindRpcMessageHolder getPayload(RpcMessage<?> message)
IntegrationAppmasterServiceClientIntegrationAppmasterServiceClient.get(RpcMessage) to
resolve the actual payload sent to Sprint Int Tcp channel.
In this class we don't care what the payload content is, thus
implementor is responsible to define it.
getPayload in class IntegrationAppmasterServiceClient<MindRpcMessageHolder>message - the rpc message
|
Spring for Apache Hadoop | ||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||