public class LlapProtocolClientProxy extends AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>
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
Constructor and Description |
---|
LlapProtocolClientProxy(int numThreads,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken) |
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 LlapProtocolClientProxy(int numThreads, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken)
public void sendSubmitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback)
public void sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request, LlapNodeId nodeId, AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback)
public void sendQueryComplete(LlapDaemonProtocolProtos.QueryCompleteRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback)
public void sendTerminateFragment(LlapDaemonProtocolProtos.TerminateFragmentRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback)
public void sendUpdateFragment(LlapDaemonProtocolProtos.UpdateFragmentRequestProto request, String host, int port, AsyncPbRpcProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.UpdateFragmentResponseProto> callback)
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)
createProtocolImpl
in class AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>
protected String getTokenUser(org.apache.hadoop.security.token.Token<LlapTokenIdentifier> token)
getTokenUser
in class AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>
protected void shutdownProtocolImpl(LlapProtocolBlockingPB client)
shutdownProtocolImpl
in class AsyncPbRpcProxy<LlapProtocolBlockingPB,LlapTokenIdentifier>
Copyright © 2022 The Apache Software Foundation. All rights reserved.