public class AMReporter
extends org.apache.hadoop.service.AbstractService
Constructor and Description |
---|
AMReporter(AtomicReference<InetSocketAddress> localAddress,
QueryFailedHandler queryFailedHandler,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
registerTask(String amLocation,
int port,
String user,
org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken,
QueryIdentifier queryIdentifier) |
void |
serviceStart() |
void |
serviceStop() |
void |
taskKilled(String amLocation,
int port,
String user,
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) |
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(AtomicReference<InetSocketAddress> localAddress, QueryFailedHandler queryFailedHandler, org.apache.hadoop.conf.Configuration conf)
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 user, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier)
public void unregisterTask(String amLocation, int port)
public void taskKilled(String amLocation, int port, String user, org.apache.hadoop.security.token.Token<org.apache.tez.common.security.JobTokenIdentifier> jobToken, QueryIdentifier queryIdentifier, org.apache.tez.dag.records.TezTaskAttemptID taskAttemptId)
Copyright © 2016 The Apache Software Foundation. All rights reserved.