org.apache.hadoop.hive.llap.daemon.impl

Class LlapProtocolServerImpl

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hive.llap.daemon.impl.LlapProtocolServerImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapManagementProtocol.BlockingInterface, LlapManagementProtocolPB, LlapProtocolBlockingPB, org.apache.hadoop.service.Service

public class LlapProtocolServerImpl
extends org.apache.hadoop.service.AbstractService
implements LlapProtocolBlockingPB, LlapManagementProtocolPB

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
LlapProtocolServerImpl(SecretManager secretManager, int numHandlers, ContainerRunner containerRunner, AtomicReference<InetSocketAddress> srvAddress, AtomicReference<InetSocketAddress> mngAddress, int srvPort, int mngPort, DaemonId daemonId)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.GetTokenResponseProto	getDelegationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.GetTokenRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.PurgeCacheResponseProto	purgeCache(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.PurgeCacheRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto	queryComplete(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request)
void	serviceStart()
void	serviceStop()
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto	sourceStateUpdated(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto	submitWork(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto	terminateFragment(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto	updateFragment(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request)

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LlapProtocolServerImpl

public LlapProtocolServerImpl(SecretManager secretManager,
                              int numHandlers,
                              ContainerRunner containerRunner,
                              AtomicReference<InetSocketAddress> srvAddress,
                              AtomicReference<InetSocketAddress> mngAddress,
                              int srvPort,
                              int mngPort,
                              DaemonId daemonId)

Method Detail

submitWork

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto submitWork(com.google.protobuf.RpcController controller,
                                                                                                          org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request)
                                                                                                   throws com.google.protobuf.ServiceException

Specified by:

submitWork in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

sourceStateUpdated

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto sourceStateUpdated(com.google.protobuf.RpcController controller,
                                                                                                                          org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request)
                                                                                                                   throws com.google.protobuf.ServiceException

Specified by:

sourceStateUpdated in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

queryComplete

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto queryComplete(com.google.protobuf.RpcController controller,
                                                                                                                org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request)
                                                                                                         throws com.google.protobuf.ServiceException

Specified by:

queryComplete in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

terminateFragment

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto terminateFragment(com.google.protobuf.RpcController controller,
                                                                                                                        org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request)
                                                                                                                 throws com.google.protobuf.ServiceException

Specified by:

terminateFragment in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

updateFragment

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto updateFragment(com.google.protobuf.RpcController controller,
                                                                                                                  org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request)
                                                                                                           throws com.google.protobuf.ServiceException

Specified by:

updateFragment in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

serviceStart

public void serviceStart()

Overrides:

serviceStart in class org.apache.hadoop.service.AbstractService

serviceStop

public void serviceStop()

Overrides:

serviceStop in class org.apache.hadoop.service.AbstractService

getDelegationToken

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.GetTokenResponseProto getDelegationToken(com.google.protobuf.RpcController controller,
                                                                                                                org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.GetTokenRequestProto request)
                                                                                                         throws com.google.protobuf.ServiceException

Specified by:

getDelegationToken in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapManagementProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

purgeCache

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.PurgeCacheResponseProto purgeCache(com.google.protobuf.RpcController controller,
                                                                                                          org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.PurgeCacheRequestProto request)
                                                                                                   throws com.google.protobuf.ServiceException

Specified by:

purgeCache in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapManagementProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException