org.apache.hadoop.hive.llap.impl

Class LlapProtocolClientImpl

java.lang.Object

org.apache.hadoop.hive.llap.impl.LlapProtocolClientImpl

All Implemented Interfaces:

org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface, LlapProtocolBlockingPB

public class LlapProtocolClientImpl
extends Object
implements LlapProtocolBlockingPB

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
LlapProtocolBlockingPB	createProxy()
LlapProtocolBlockingPB	getProxy()
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto	queryComplete(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto	sourceStateUpdated(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto	submitWork(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto	terminateFragment(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request)
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto	updateFragment(com.google.protobuf.RpcController controller, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LlapProtocolClientImpl

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)

Method Detail

submitWork

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkResponseProto submitWork(com.google.protobuf.RpcController controller,
                                                                                                          org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request)
                                                                                                   throws com.google.protobuf.ServiceException

Specified by:

submitWork in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

sourceStateUpdated

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto sourceStateUpdated(com.google.protobuf.RpcController controller,
                                                                                                                          org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request)
                                                                                                                   throws com.google.protobuf.ServiceException

Specified by:

sourceStateUpdated in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

queryComplete

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteResponseProto queryComplete(com.google.protobuf.RpcController controller,
                                                                                                                org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.QueryCompleteRequestProto request)
                                                                                                         throws com.google.protobuf.ServiceException

Specified by:

queryComplete in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

terminateFragment

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentResponseProto terminateFragment(com.google.protobuf.RpcController controller,
                                                                                                                        org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.TerminateFragmentRequestProto request)
                                                                                                                 throws com.google.protobuf.ServiceException

Specified by:

terminateFragment in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

updateFragment

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentResponseProto updateFragment(com.google.protobuf.RpcController controller,
                                                                                                                  org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.UpdateFragmentRequestProto request)
                                                                                                           throws com.google.protobuf.ServiceException

Specified by:

updateFragment in interface org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.LlapDaemonProtocol.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getProxy

public LlapProtocolBlockingPB getProxy()
                                throws IOException

Throws:

IOException

createProxy

public LlapProtocolBlockingPB createProxy()
                                   throws IOException

Throws:

IOException