public class AMReporter
extends org.apache.hadoop.service.AbstractService
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 |
---|---|
void |
queryComplete(QueryIdentifier queryIdentifier) |
void |
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) |
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 void 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)
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)
Copyright © 2021 The Apache Software Foundation. All rights reserved.