public class PartitionerDefinedVertexManager
extends org.apache.tez.dag.api.VertexManagerPlugin
Constructor and Description |
---|
PartitionerDefinedVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context) |
Modifier and Type | Method and Description |
---|---|
void |
initialize() |
void |
onRootVertexInitialized(java.lang.String inputName,
org.apache.tez.dag.api.InputDescriptor inputDescriptor,
java.util.List<org.apache.tez.runtime.api.Event> events) |
void |
onSourceTaskCompleted(java.lang.String srcVertexName,
java.lang.Integer srcTaskId) |
void |
onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent) |
void |
onVertexStarted(java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> completions) |
void |
onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate) |
public PartitionerDefinedVertexManager(org.apache.tez.dag.api.VertexManagerPluginContext context)
public void initialize()
initialize
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onVertexStateUpdated(org.apache.tez.dag.api.event.VertexStateUpdate stateUpdate) throws java.lang.Exception
onVertexStateUpdated
in class org.apache.tez.dag.api.VertexManagerPlugin
java.lang.Exception
public void onRootVertexInitialized(java.lang.String inputName, org.apache.tez.dag.api.InputDescriptor inputDescriptor, java.util.List<org.apache.tez.runtime.api.Event> events)
onRootVertexInitialized
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onSourceTaskCompleted(java.lang.String srcVertexName, java.lang.Integer srcTaskId)
onSourceTaskCompleted
in class org.apache.tez.dag.api.VertexManagerPlugin
public void onVertexManagerEventReceived(org.apache.tez.runtime.api.events.VertexManagerEvent vmEvent) throws java.lang.Exception
onVertexManagerEventReceived
in class org.apache.tez.dag.api.VertexManagerPlugin
java.lang.Exception
public void onVertexStarted(java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> completions)
onVertexStarted
in class org.apache.tez.dag.api.VertexManagerPlugin
Copyright © 2007-2025 The Apache Software Foundation