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) |
Modifier and Type | Method and Description |
---|---|
LlapProtocolBlockingPB |
createProxy() |
LlapProtocolBlockingPB |
getProxy() |
LlapDaemonProtocolProtos.QueryCompleteResponseProto |
queryComplete(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.QueryCompleteRequestProto request) |
LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto |
sourceStateUpdated(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
LlapDaemonProtocolProtos.SubmitWorkResponseProto |
submitWork(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.SubmitWorkRequestProto request) |
LlapDaemonProtocolProtos.TerminateFragmentResponseProto |
terminateFragment(com.google.protobuf.RpcController controller,
LlapDaemonProtocolProtos.TerminateFragmentRequestProto request) |
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 LlapProtocolBlockingPB getProxy() throws IOException
IOException
public LlapProtocolBlockingPB createProxy() throws IOException
IOException
Copyright © 2021 The Apache Software Foundation. All rights reserved.