public class LlapProtocolClientImpl extends Object implements LlapProtocolBlockingPB
Constructor and Description |
---|
LlapProtocolClientImpl(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) |
public LlapProtocolClientImpl(org.apache.hadoop.conf.Configuration conf, String hostname, int port, org.apache.hadoop.security.UserGroupInformation ugi, @Nullable org.apache.hadoop.io.retry.RetryPolicy retryPolicy, @Nullable SocketFactory socketFactory)
public LlapDaemonProtocolProtos.SubmitWorkResponseProto submitWork(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SubmitWorkRequestProto request) throws com.google.protobuf.ServiceException
submitWork
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto sourceStateUpdated(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) throws com.google.protobuf.ServiceException
sourceStateUpdated
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.QueryCompleteResponseProto queryComplete(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.QueryCompleteRequestProto request) throws com.google.protobuf.ServiceException
queryComplete
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.TerminateFragmentResponseProto terminateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.TerminateFragmentRequestProto request) throws com.google.protobuf.ServiceException
terminateFragment
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapDaemonProtocolProtos.UpdateFragmentResponseProto updateFragment(com.google.protobuf.RpcController controller, LlapDaemonProtocolProtos.UpdateFragmentRequestProto request) throws com.google.protobuf.ServiceException
updateFragment
in interface LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface
com.google.protobuf.ServiceException
public LlapProtocolBlockingPB getProxy() throws IOException
IOException
public LlapProtocolBlockingPB createProxy() throws IOException
IOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.