public class LlapTaskUmbilicalServer extends Object
Modifier and Type | Class and Description |
---|---|
static class |
LlapTaskUmbilicalServer.LlapUmbilicalExternalPolicyProvider |
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.ipc.Server |
server |
Constructor and Description |
---|
LlapTaskUmbilicalServer(org.apache.hadoop.conf.Configuration conf,
LlapTaskUmbilicalProtocol umbilical,
int numHandlers) |
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() |
public LlapTaskUmbilicalServer(org.apache.hadoop.conf.Configuration conf, LlapTaskUmbilicalProtocol umbilical, int numHandlers) throws IOException
IOException
public InetSocketAddress getAddress()
public int getNumOpenConnections()
public void addTokenForJob(String tokenIdentifier, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> token)
public void removeTokenForJob(String tokenIdentifier)
public void shutdownServer()
Copyright © 2022 The Apache Software Foundation. All rights reserved.