public class LlapTaskUmbilicalExternalClient extends org.apache.hadoop.service.AbstractService implements Closeable
Modifier and Type | Class and Description |
---|---|
static interface |
LlapTaskUmbilicalExternalClient.LlapTaskUmbilicalExternalResponder |
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> |
sessionToken |
protected String |
tokenIdentifier |
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) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
getAddress() |
void |
serviceStart() |
void |
serviceStop() |
void |
submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
String llapHost,
int llapPort)
Submit the work for actual execution.
|
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
protected final String tokenIdentifier
protected final org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> sessionToken
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)
public void serviceStart() throws IOException
serviceStart
in class org.apache.hadoop.service.AbstractService
IOException
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public InetSocketAddress getAddress()
public void submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request, String llapHost, int llapPort)
com.google.protobuf.InvalidProtocolBufferException
Copyright © 2021 The Apache Software Foundation. All rights reserved.