@InterfaceStability.Unstable @InterfaceAudience.Public public abstract class VertexManagerPlugin extends Object
| Constructor and Description |
|---|
VertexManagerPlugin(VertexManagerPluginContext context)
Crete an instance of the VertexManagerPlugin.
|
| Modifier and Type | Method and Description |
|---|---|
VertexManagerPluginContext |
getContext()
Return ahe
VertexManagerPluginContext for this specific instance of
the vertex manager. |
abstract void |
initialize()
Initialize the plugin.
|
abstract void |
onRootVertexInitialized(String inputName,
InputDescriptor inputDescriptor,
List<Event> events)
Notification that the inputs of this vertex have initialized
|
void |
onSourceTaskCompleted(String srcVertexName,
Integer taskId)
Deprecated.
|
void |
onSourceTaskCompleted(org.apache.tez.runtime.api.TaskAttemptIdentifier attempt)
Notification of a source vertex task completion.
|
abstract void |
onVertexManagerEventReceived(VertexManagerEvent vmEvent)
Notification of an event directly sent to this vertex manager
|
void |
onVertexStarted(List<org.apache.tez.runtime.api.TaskAttemptIdentifier> completions)
Notification that the vertex is ready to start running tasks
|
void |
onVertexStarted(Map<String,List<Integer>> completions)
Deprecated.
|
void |
onVertexStateUpdated(VertexStateUpdate stateUpdate)
Receive notifications on vertex state changes.
|
public VertexManagerPlugin(VertexManagerPluginContext context)
context - vertex manager plugin context which can be used to access the
payload, vertex properties, etcpublic abstract void initialize()
throws Exception
Exception@Deprecated public void onVertexStarted(Map<String,List<Integer>> completions) throws Exception
Exceptionpublic void onVertexStarted(List<org.apache.tez.runtime.api.TaskAttemptIdentifier> completions) throws Exception
completions - All the source task attempts that have already completedException@Deprecated public void onSourceTaskCompleted(String srcVertexName, Integer taskId) throws Exception
Exceptionpublic void onSourceTaskCompleted(org.apache.tez.runtime.api.TaskAttemptIdentifier attempt)
throws Exception
attempt - Identifier of the task attempt that completedExceptionpublic abstract void onVertexManagerEventReceived(VertexManagerEvent vmEvent) throws Exception
vmEvent - Exceptionpublic abstract void onRootVertexInitialized(String inputName, InputDescriptor inputDescriptor, List<Event> events) throws Exception
inputName - inputDescriptor - events - Exceptionpublic final VertexManagerPluginContext getContext()
VertexManagerPluginContext for this specific instance of
the vertex manager.VertexManagerPluginContext for the inputpublic void onVertexStateUpdated(VertexStateUpdate stateUpdate) throws Exception
VertexManagerPluginContext.registerForVertexStateUpdates(String, java.util.Set)
. Notifications will be received for all registered state changes, and not
just for the latest state update. They will be in order in which the state
change occurred.
onVertexStarted(Map) etc. and
multi-threading/concurrency implications must be considered.stateUpdate - an event indicating the name of the vertex, and it's updated
state. Additional information may be available for specific
events, Look at the type hierarchy for
VertexStateUpdateExceptionCopyright © 2024 Apache Software Foundation. All rights reserved.