public class LlapProtocolClientProxy
extends org.apache.hadoop.service.AbstractService
Modifier and Type | Class and Description |
---|---|
static interface |
LlapProtocolClientProxy.ExecuteRequestCallback<T extends com.google.protobuf.Message> |
Constructor and Description |
---|
LlapProtocolClientProxy(int numThreads,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken) |
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 serviceStart()
serviceStart
in class org.apache.hadoop.service.AbstractService
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public void sendSubmitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request, String host, int port, LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SubmitWorkResponseProto> callback)
public void sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request, LlapNodeId nodeId, LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback)
public void sendQueryComplete(LlapDaemonProtocolProtos.QueryCompleteRequestProto request, String host, int port, LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.QueryCompleteResponseProto> callback)
public void sendTerminateFragment(LlapDaemonProtocolProtos.TerminateFragmentRequestProto request, String host, int port, LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.TerminateFragmentResponseProto> callback)
Copyright © 2021 The Apache Software Foundation. All rights reserved.