org.apache.hadoop.hive.ql.exec.tez

Class LlapPluginEndpointClientImpl

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hive.llap.AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>

org.apache.hadoop.hive.ql.exec.tez.LlapPluginEndpointClientImpl

All Implemented Interfaces:

Closeable, AutoCloseable, LlapPluginEndpointClient, org.apache.hadoop.service.Service

public class LlapPluginEndpointClientImpl
extends AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>
implements LlapPluginEndpointClient

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.llap.AsyncPbRpcProxy

AsyncPbRpcProxy.CallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>, AsyncPbRpcProxy.ExecuteRequestCallback<T extends com.google.protobuf.Message>, AsyncPbRpcProxy.NodeCallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>, AsyncPbRpcProxy.RequestManager

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.exec.tez.LlapPluginEndpointClient

LlapPluginEndpointClient.UpdateRequestContext

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

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
LlapPluginEndpointClientImpl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token, int expectedNodes)

Method Summary

Modifier and Type	Method and Description
protected LlapPluginProtocolPB	createProtocolImpl(org.apache.hadoop.conf.Configuration conf, String hostname, int port, org.apache.hadoop.security.UserGroupInformation ugi, org.apache.hadoop.io.retry.RetryPolicy retryPolicy, SocketFactory socketFactory)
protected String	getTokenUser(org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)
void	sendUpdateQuery(org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryRequestProto request, AmPluginNode node, LlapPluginEndpointClient.UpdateRequestContext callback)
protected void	shutdownProtocolImpl(LlapPluginProtocolPB proxy)

Methods inherited from class org.apache.hadoop.hive.llap.AsyncPbRpcProxy

getProxy, queueRequest, serviceStart, serviceStop

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

LlapPluginEndpointClientImpl

public LlapPluginEndpointClientImpl(org.apache.hadoop.conf.Configuration conf,
                                    org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token,
                                    int expectedNodes)

Method Detail

createProtocolImpl

protected LlapPluginProtocolPB createProtocolImpl(org.apache.hadoop.conf.Configuration conf,
                                                  String hostname,
                                                  int port,
                                                  org.apache.hadoop.security.UserGroupInformation ugi,
                                                  org.apache.hadoop.io.retry.RetryPolicy retryPolicy,
                                                  SocketFactory socketFactory)

Specified by:

createProtocolImpl in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>

shutdownProtocolImpl

protected void shutdownProtocolImpl(LlapPluginProtocolPB proxy)

Specified by:

shutdownProtocolImpl in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>

getTokenUser

protected String getTokenUser(org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)

Specified by:

getTokenUser in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>

sendUpdateQuery

public void sendUpdateQuery(org.apache.hadoop.hive.llap.plugin.rpc.LlapPluginProtocolProtos.UpdateQueryRequestProto request,
                            AmPluginNode node,
                            LlapPluginEndpointClient.UpdateRequestContext callback)

Specified by:

sendUpdateQuery in interface LlapPluginEndpointClient