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(String srcVertexName, Integer taskId)
void	onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent)
void	onVertexStarted(Map<String,List<Integer>> completions)
void	onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate)

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

getContext

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(Map<String,List<Integer>> completions)

Specified by:

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

onSourceTaskCompleted

public void onSourceTaskCompleted(String srcVertexName,
                         Integer taskId)

Specified by:

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