public class LlapTaskUmbilicalExternalClient
extends org.apache.hadoop.service.AbstractService
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) |
Modifier and Type | Method and Description |
---|---|
InetSocketAddress |
getAddress() |
void |
serviceStart() |
void |
serviceStop() |
void |
submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto submitWorkRequestProto,
String llapHost,
int llapPort,
List<org.apache.tez.runtime.api.impl.TezEvent> tezEvents)
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)
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 submitWorkRequestProto, String llapHost, int llapPort, List<org.apache.tez.runtime.api.impl.TezEvent> tezEvents)
submitWorkRequestProto
- Copyright © 2016 The Apache Software Foundation. All rights reserved.