org.apache.hadoop.hive.llap

Class AsyncPbRpcProxy<ProtocolType,TokenType extends org.apache.hadoop.security.token.TokenIdentifier>

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hive.llap.AsyncPbRpcProxy<ProtocolType,TokenType>

All Implemented Interfaces:

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

Direct Known Subclasses:

LlapPluginEndpointClientImpl, LlapProtocolClientProxy

public abstract class AsyncPbRpcProxy<ProtocolType,TokenType extends org.apache.hadoop.security.token.TokenIdentifier>
extends org.apache.hadoop.service.AbstractService

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AsyncPbRpcProxy.CallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>
static interface	AsyncPbRpcProxy.ExecuteRequestCallback<T extends com.google.protobuf.Message>
protected static class	AsyncPbRpcProxy.NodeCallableRequest<REQUEST extends com.google.protobuf.Message,RESPONSE extends com.google.protobuf.Message>
static class	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
AsyncPbRpcProxy(String name, int numThreads, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.Token<TokenType> token, long connectionTimeoutMs, long retrySleepMs, int expectedNodes, int maxPerNode)

Method Summary

Modifier and Type	Method and Description
protected abstract ProtocolType	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 ProtocolType	getProxy(LlapNodeId nodeId, org.apache.hadoop.security.token.Token<TokenType> nodeToken)
protected abstract String	getTokenUser(org.apache.hadoop.security.token.Token<TokenType> token)
protected void	queueRequest(AsyncPbRpcProxy.CallableRequest<?,?> request)
void	serviceStart()
void	serviceStop()
protected abstract void	shutdownProtocolImpl(ProtocolType proxy)

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

AsyncPbRpcProxy

public AsyncPbRpcProxy(String name,
                       int numThreads,
                       org.apache.hadoop.conf.Configuration conf,
                       org.apache.hadoop.security.token.Token<TokenType> token,
                       long connectionTimeoutMs,
                       long retrySleepMs,
                       int expectedNodes,
                       int maxPerNode)

Method Detail

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

queueRequest

protected final void queueRequest(AsyncPbRpcProxy.CallableRequest<?,?> request)

getProxy

protected final ProtocolType getProxy(LlapNodeId nodeId,
                                      org.apache.hadoop.security.token.Token<TokenType> nodeToken)

Parameters:

nodeId - Hostname + post.

nodeToken - A custom node token. If not specified, the default token is used.

Returns:

the protocol client implementation for the node.

createProtocolImpl

protected abstract ProtocolType 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)

shutdownProtocolImpl

protected abstract void shutdownProtocolImpl(ProtocolType proxy)

getTokenUser

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