org.apache.hadoop.hive.llap.tez

Class LlapProtocolClientProxy

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hive.llap.AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>

org.apache.hadoop.hive.llap.tez.LlapProtocolClientProxy

All Implemented Interfaces:

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

public class LlapProtocolClientProxy
extends AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>

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.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor and Description
LlapProtocolClientProxy(int numThreads, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken)

Method Summary

Modifier and Type	Method and Description
protected LlapProtocolBlockingPB	createProtocolImpl(org.apache.hadoop.conf.Configuration config, 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<LlapTokenIdentifier> token)
void	sendQueryComplete(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback)
void	sendSourceStateUpdate(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request, LlapNodeId nodeId, AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback)
void	sendSubmitWork(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback)
void	sendTerminateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback)
void	sendUpdateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto> callback)
protected void	shutdownProtocolImpl(LlapProtocolBlockingPB client)

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

LlapProtocolClientProxy

public LlapProtocolClientProxy(int numThreads,
                               org.apache.hadoop.conf.Configuration conf,
                               org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken)

Method Detail

sendSubmitWork

public void sendSubmitWork(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
                           String host,
                           int port,
                           AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback)

sendSourceStateUpdate

public void sendSourceStateUpdate(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
                                  LlapNodeId nodeId,
                                  AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback)

sendQueryComplete

public void sendQueryComplete(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request,
                              String host,
                              int port,
                              AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback)

sendTerminateFragment

public void sendTerminateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request,
                                  String host,
                                  int port,
                                  AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback)

sendUpdateFragment

public void sendUpdateFragment(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request,
                               String host,
                               int port,
                               AsyncPbRpcProxy.ExecuteRequestCallback<org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto> callback)

createProtocolImpl

protected LlapProtocolBlockingPB createProtocolImpl(org.apache.hadoop.conf.Configuration config,
                                                    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<LlapProtocolBlockingPB,LlapTokenIdentifier>

getTokenUser

protected String getTokenUser(org.apache.hadoop.security.token.Token<LlapTokenIdentifier> token)

Specified by:

getTokenUser in class AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>

shutdownProtocolImpl

protected void shutdownProtocolImpl(LlapProtocolBlockingPB client)

Specified by:

shutdownProtocolImpl in class AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>