@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
|
abstract void |
onSourceTaskCompleted(String srcVertexName,
Integer taskId)
Notification of a source vertex completion.
|
abstract void |
onVertexManagerEventReceived(VertexManagerEvent vmEvent)
Notification of an event directly sent to this vertex manager
|
abstract void |
onVertexStarted(Map<String,List<Integer>> completions)
Notification that the vertex is ready to start running tasks
|
public VertexManagerPlugin(VertexManagerPluginContext context)
context
- vertex manager plugin context which can be used to access the
payload, vertex properties, etcpublic abstract void initialize()
public abstract void onVertexStarted(Map<String,List<Integer>> completions)
completions
- Source vertices and all their tasks that have already completedpublic abstract void onSourceTaskCompleted(String srcVertexName, Integer taskId)
srcVertexName
- taskId
- Index of the task that completedpublic abstract void onVertexManagerEventReceived(VertexManagerEvent vmEvent)
vmEvent
- public abstract void onRootVertexInitialized(String inputName, InputDescriptor inputDescriptor, List<Event> events)
inputName
- inputDescriptor
- events
- public final VertexManagerPluginContext getContext()
VertexManagerPluginContext
for this specific instance of
the vertex manager.VertexManagerPluginContext
for the inputCopyright © 2014 Apache Software Foundation. All rights reserved.