org.apache.hadoop.hive.llap.tezplugins.helpers

Class LlapTaskUmbilicalServer

java.lang.Object

org.apache.hadoop.hive.llap.tezplugins.helpers.LlapTaskUmbilicalServer

public class LlapTaskUmbilicalServer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LlapTaskUmbilicalServer.LlapUmbilicalExternalPolicyProvider

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.ipc.Server	server

Constructor Summary

Constructors

Constructor and Description
LlapTaskUmbilicalServer(org.apache.hadoop.conf.Configuration conf, LlapTaskUmbilicalProtocol umbilical, int numHandlers)

Method Summary

Modifier and Type	Method and Description
void	addTokenForJob(String tokenIdentifier, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)
InetSocketAddress	getAddress()
int	getNumOpenConnections()
void	removeTokenForJob(String tokenIdentifier)
void	shutdownServer()

Methods inherited from class java.lang.Object

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

Field Detail

server

protected volatile org.apache.hadoop.ipc.Server server

Constructor Detail

LlapTaskUmbilicalServer

public LlapTaskUmbilicalServer(org.apache.hadoop.conf.Configuration conf,
                               LlapTaskUmbilicalProtocol umbilical,
                               int numHandlers)
                        throws IOException

Throws:

IOException

Method Detail

getAddress

public InetSocketAddress getAddress()

getNumOpenConnections

public int getNumOpenConnections()

addTokenForJob

public void addTokenForJob(String tokenIdentifier,
                           org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)

removeTokenForJob

public void removeTokenForJob(String tokenIdentifier)

shutdownServer

public void shutdownServer()