org.apache.hadoop.hive.llap.tezplugins.endpoint

Class LlapPluginServerImpl

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hive.llap.tezplugins.endpoint.LlapPluginServerImpl

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.LlapPluginProtocol.BlockingInterface, LlapPluginProtocolPB, org.apache.hadoop.service.Service

public class LlapPluginServerImpl
extends org.apache.hadoop.service.AbstractService
implements LlapPluginProtocolPB

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
LlapPluginServerImpl(org.apache.hadoop.security.token.SecretManager<org.apache.tez.common.security.JobTokenIdentifier> secretManager, int numHandlers, LlapTaskSchedulerService parent)

Method Summary

Modifier and Type	Method and Description
int	getActualPort()
void	serviceStart()
void	serviceStop()
org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryResponseProto	updateQuery(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryRequestProto 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

LlapPluginServerImpl

public LlapPluginServerImpl(org.apache.hadoop.security.token.SecretManager<org.apache.tez.common.security.JobTokenIdentifier> secretManager,
                            int numHandlers,
                            LlapTaskSchedulerService parent)

Method Detail

updateQuery

public org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryResponseProto updateQuery(com.google.protobuf.RpcController controller,
                                                                                                            org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryRequestProto request)
                                                                                                     throws com.google.protobuf.ServiceException

Specified by:

updateQuery in interface org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.LlapPluginProtocol.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

getActualPort

public int getActualPort()