org.apache.hadoop.hive.llap.ext

Class LlapTaskUmbilicalExternalClient

java.lang.Object

org.apache.hadoop.hive.llap.ext.LlapTaskUmbilicalExternalClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class LlapTaskUmbilicalExternalClient
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	LlapTaskUmbilicalExternalClient.LlapTaskUmbilicalExternalResponder

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier>	sessionToken
protected String	tokenIdentifier

Constructor Summary

Constructors

Constructor and Description
LlapTaskUmbilicalExternalClient(org.apache.hadoop.conf.Configuration conf, String tokenIdentifier, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> sessionToken, LlapTaskUmbilicalExternalClient.LlapTaskUmbilicalExternalResponder responder, org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken)

Method Summary

Modifier and Type	Method and Description
void	close()
InetSocketAddress	getAddress()
void	submitWork(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request, String llapHost, int llapPort) Submit the work for actual execution.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

tokenIdentifier

protected final String tokenIdentifier

sessionToken

protected final org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> sessionToken

Constructor Detail

LlapTaskUmbilicalExternalClient

public LlapTaskUmbilicalExternalClient(org.apache.hadoop.conf.Configuration conf,
                                       String tokenIdentifier,
                                       org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> sessionToken,
                                       LlapTaskUmbilicalExternalClient.LlapTaskUmbilicalExternalResponder responder,
                                       org.apache.hadoop.security.token.Token<LlapTokenIdentifier> llapToken)

Method Detail

getAddress

public InetSocketAddress getAddress()

submitWork

public void submitWork(org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
                       String llapHost,
                       int llapPort)

Submit the work for actual execution.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

toString

public String toString()

Overrides:

toString in class Object