public class AMReporter
extends org.apache.hadoop.service.AbstractService
Modifier and Type | Class and Description |
---|---|
protected class |
AMReporter.AMNodeInfo |
Constructor and Description |
---|
AMReporter(int numExecutors,
int maxThreads,
AtomicReference<InetSocketAddress> localAddress,
QueryFailedHandler queryFailedHandler,
org.apache.hadoop.conf.Configuration conf,
DaemonId daemonId,
SocketFactory socketFactory) |
Modifier and Type | Method and Description |
---|---|
protected LlapTaskUmbilicalProtocol |
createUmbilical(AMReporter.AMNodeInfo amNodeInfo) |
void |
queryComplete(QueryIdentifier queryIdentifier) |
AMReporter.AMNodeInfo |
registerTask(String amLocation,
int port,
String umbilicalUser,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier queryIdentifier,
org.apache.tez.dag.records.TezTaskAttemptID attemptId,
boolean isGuaranteed) |
void |
serviceStart() |
void |
serviceStop() |
void |
taskKilled(String amLocation,
int port,
String umbilicalUser,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier queryIdentifier,
org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId) |
void |
unregisterTask(String amLocation,
int port,
QueryIdentifier queryIdentifier,
org.apache.tez.dag.records.TezTaskAttemptID ta) |
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, serviceInit, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public AMReporter(int numExecutors, int maxThreads, AtomicReference<InetSocketAddress> localAddress, QueryFailedHandler queryFailedHandler, org.apache.hadoop.conf.Configuration conf, DaemonId daemonId, SocketFactory socketFactory)
public void serviceStart()
serviceStart
in class org.apache.hadoop.service.AbstractService
public void serviceStop()
serviceStop
in class org.apache.hadoop.service.AbstractService
public AMReporter.AMNodeInfo registerTask(String amLocation, int port, String umbilicalUser, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID attemptId, boolean isGuaranteed)
public void unregisterTask(String amLocation, int port, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID ta)
public void taskKilled(String amLocation, int port, String umbilicalUser, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)
public void queryComplete(QueryIdentifier queryIdentifier)
protected LlapTaskUmbilicalProtocol createUmbilical(AMReporter.AMNodeInfo amNodeInfo) throws IOException, InterruptedException
IOException
InterruptedException
Copyright © 2022 The Apache Software Foundation. All rights reserved.