public class LlapProtocolServerImpl extends org.apache.hadoop.service.AbstractService implements LlapProtocolBlockingPB, LlapManagementProtocolPB
Constructor and Description |
---|
LlapProtocolServerImpl(SecretManager secretManager,
int numHandlers,
ContainerRunner containerRunner,
AtomicReference<InetSocketAddress> srvAddress,
AtomicReference<InetSocketAddress> mngAddress,
int srvPort,
int mngPort,
DaemonId daemonId) |
Modifier and Type | Method and Description |
---|---|
LlapDaemonProtocolProtos.GetTokenResponseProto |
getDelegationToken(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.GetTokenRequestProto request) |
LlapDaemonProtocolProtos.QueryCompleteResponseProto |
queryComplete(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.QueryCompleteRequestProto request) |
void |
serviceStart() |
void |
serviceStop() |
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
LlapDaemonProtocolProtos.TerminateFragmentResponseProto |
terminateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.TerminateFragmentRequestProto request) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public LlapProtocolServerImpl(SecretManager secretManager, int numHandlers, ContainerRunner containerRunner, AtomicReference<InetSocketAddress> srvAddress, AtomicReference<InetSocketAddress> mngAddress, int srvPort, int mngPort, DaemonId daemonId)
public LlapDaemonProtocolProtos.SubmitWorkResponseProto submitWork(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SubmitWorkRequestProto request) throws com.google.protobuf.ServiceException
submitWork
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto sourceStateUpdated(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) throws com.google.protobuf.ServiceException
sourceStateUpdated
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.QueryCompleteResponseProto queryComplete(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.QueryCompleteRequestProto request) throws com.google.protobuf.ServiceException
queryComplete
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.TerminateFragmentResponseProto terminateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.TerminateFragmentRequestProto request) throws com.google.protobuf.ServiceException
terminateFragment
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public void serviceStart()
serviceStart
in class org.apache.hadoop.service.AbstractService
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public LlapDaemonProtocolProtos.GetTokenResponseProto getDelegationToken(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.GetTokenRequestProto request) throws com.google.protobuf.ServiceException
getDelegationToken
in interface LlapDaemonProtocolProtos.LlapManagementProtocol.BlockingInterface
com.google.protobuf.ServiceException
Copyright © 2021 The Apache Software Foundation. All rights reserved.