org.apache.tez.dag.library.vertexmanager

Class InputReadyVertexManager

java.lang.Object

org.apache.tez.dag.api.VertexManagerPlugin

org.apache.tez.dag.library.vertexmanager.InputReadyVertexManager

@InterfaceAudience.Private
public class InputReadyVertexManager
extends org.apache.tez.dag.api.VertexManagerPlugin

Constructor Summary

Constructors

Constructor and Description
InputReadyVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Summary

Methods

Modifier and Type	Method and Description
void	initialize()
void	onRootVertexInitialized(String inputName, org.apache.tez.dag.api.InputDescriptor inputDescriptor, List<org.apache.tez.runtime.api.Event> events)
void	onSourceTaskCompleted(org.apache.tez.runtime.api.TaskAttemptIdentifier attempt)
void	onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)
void	onVertexStarted(List<org.apache.tez.runtime.api.TaskAttemptIdentifier> completions)
void	onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)

Methods inherited from class org.apache.tez.dag.api.VertexManagerPlugin

getContext, onSourceTaskCompleted, onVertexStarted

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputReadyVertexManager

public InputReadyVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context)

Method Detail

initialize

public void initialize()

Specified by:

initialize in class org.apache.tez.dag.api.VertexManagerPlugin

onVertexStateUpdated

public void onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)
                          throws Exception

Overrides:

onVertexStateUpdated in class org.apache.tez.dag.api.VertexManagerPlugin

Throws:

Exception

onVertexStarted

public void onVertexStarted(List<org.apache.tez.runtime.api.TaskAttemptIdentifier> completions)

Overrides:

onVertexStarted in class org.apache.tez.dag.api.VertexManagerPlugin

onSourceTaskCompleted

public void onSourceTaskCompleted(org.apache.tez.runtime.api.TaskAttemptIdentifier attempt)

Overrides:

onSourceTaskCompleted in class org.apache.tez.dag.api.VertexManagerPlugin

onVertexManagerEventReceived

public void onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)

Specified by:

onVertexManagerEventReceived in class org.apache.tez.dag.api.VertexManagerPlugin

onRootVertexInitialized

public void onRootVertexInitialized(String inputName,
                           org.apache.tez.dag.api.InputDescriptor inputDescriptor,
                           List<org.apache.tez.runtime.api.Event> events)

Specified by:

onRootVertexInitialized in class org.apache.tez.dag.api.VertexManagerPlugin