public class LlapPluginEndpointClientImpl extends AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier> implements LlapPluginEndpointClient
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
LlapPluginEndpointClient.UpdateRequestContext
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) |
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(LlapPluginProtocolProtos.UpdateQueryRequestProto request,
AmPluginNode node,
LlapPluginEndpointClient.UpdateRequestContext callback) |
protected void |
shutdownProtocolImpl(LlapPluginProtocolPB proxy) |
getProxy, queueRequest, serviceStart, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public LlapPluginEndpointClientImpl(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token, int expectedNodes)
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)
createProtocolImpl
in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>
protected void shutdownProtocolImpl(LlapPluginProtocolPB proxy)
shutdownProtocolImpl
in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>
protected String getTokenUser(org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)
getTokenUser
in class AsyncPbRpcProxy<LlapPluginProtocolPB,org.apache.tez.common.security.JobTokenIdentifier>
public void sendUpdateQuery(LlapPluginProtocolProtos.UpdateQueryRequestProto request, AmPluginNode node, LlapPluginEndpointClient.UpdateRequestContext callback)
sendUpdateQuery
in interface LlapPluginEndpointClient
Copyright © 2022 The Apache Software Foundation. All rights reserved.