@InterfaceAudience.Public @InterfaceStability.Unstable public abstract class EdgeManagerPlugin extends Object
Constructor and Description |
---|
EdgeManagerPlugin(EdgeManagerPluginContext context)
Create an instance of the EdgeManagerPlugin.
|
Modifier and Type | Method and Description |
---|---|
EdgeManagerPluginContext |
getContext()
Return ahe
EdgeManagerPluginContext for this specific instance of
the vertex manager. |
abstract int |
getNumDestinationConsumerTasks(int sourceTaskIndex)
Get the number of destination tasks that consume data from the source task
|
abstract int |
getNumDestinationTaskPhysicalInputs(int destinationTaskIndex)
Get the number of physical inputs on the destination task
|
abstract int |
getNumSourceTaskPhysicalOutputs(int sourceTaskIndex)
Get the number of physical outputs on the source task
|
abstract void |
initialize()
Initializes the EdgeManagerPlugin.
|
abstract void |
routeDataMovementEventToDestination(DataMovementEvent event,
int sourceTaskIndex,
int sourceOutputIndex,
Map<Integer,List<Integer>> destinationTaskAndInputIndices)
Return the routing information to inform consumers about the source task
output that is now available.
|
abstract int |
routeInputErrorEventToSource(InputReadErrorEvent event,
int destinationTaskIndex,
int destinationFailedInputIndex)
Return the source task index to which to send the input error event
|
abstract void |
routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex,
Map<Integer,List<Integer>> destinationTaskAndInputIndices)
Return the routing information to inform consumers about the failure of a
source task whose outputs have been potentially lost.
|
public EdgeManagerPlugin(EdgeManagerPluginContext context)
context
- the context within which this EdgeManagerPlugin will run. Includes
information like configuration which the user may have specified
while setting up the edge.public abstract void initialize()
EdgeManagerPluginContext
when the
EdgeManagerPlugin is replaced.public abstract int getNumDestinationTaskPhysicalInputs(int destinationTaskIndex)
destinationTaskIndex
- Index of destination task for which number of
inputs is neededpublic abstract int getNumSourceTaskPhysicalOutputs(int sourceTaskIndex)
sourceTaskIndex
- Index of the source task for which number of outputs
is neededpublic abstract void routeDataMovementEventToDestination(DataMovementEvent event, int sourceTaskIndex, int sourceOutputIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)
event
- Data movement event that contains the output informationsourceTaskIndex
- Source task that produced the eventsourceOutputIndex
- Index of the physical output on the source task that produced the
eventdestinationTaskAndInputIndices
- Map via which the routing information is returnedpublic abstract void routeInputSourceTaskFailedEventToDestination(int sourceTaskIndex, Map<Integer,List<Integer>> destinationTaskAndInputIndices)
sourceTaskIndex
- Source taskdestinationTaskAndInputIndices
- Map via which the routing information is returnedpublic abstract int getNumDestinationConsumerTasks(int sourceTaskIndex)
sourceTaskIndex
- Source task indexpublic abstract int routeInputErrorEventToSource(InputReadErrorEvent event, int destinationTaskIndex, int destinationFailedInputIndex)
event
- Input read error event. Has more information about the errordestinationTaskIndex
- Destination task that reported the errordestinationFailedInputIndex
- Index of the physical input on the destination task that reported
the errorpublic EdgeManagerPluginContext getContext()
EdgeManagerPluginContext
for this specific instance of
the vertex manager.EdgeManagerPluginContext
for the inputCopyright © 2014 Apache Software Foundation. All rights reserved.