org.apache.tez.dag.app

Interface TaskAttemptListener

All Known Implementing Classes:

TaskAttemptListenerImpTezDag

public interface TaskAttemptListener

This class listens for changes to the state of a Task.

Method Summary

Methods

Modifier and Type	Method and Description
void	dagComplete(DAG dag)
void	dagSubmitted()
InetSocketAddress	getAddress()
void	registerRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	registerTaskAttempt(AMContainerTask amContainerTask, org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	unregisterRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)
void	unregisterTaskAttempt(org.apache.tez.dag.records.TezTaskAttemptID attemptID)

Method Detail

getAddress

InetSocketAddress getAddress()

registerRunningContainer

void registerRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)

registerTaskAttempt

void registerTaskAttempt(AMContainerTask amContainerTask,
                       org.apache.hadoop.yarn.api.records.ContainerId containerId)

unregisterRunningContainer

void unregisterRunningContainer(org.apache.hadoop.yarn.api.records.ContainerId containerId)

unregisterTaskAttempt

void unregisterTaskAttempt(org.apache.tez.dag.records.TezTaskAttemptID attemptID)

dagComplete

void dagComplete(DAG dag)

dagSubmitted

void dagSubmitted()