public class FlatTopology extends Object implements Topology
Constructor and Description |
---|
FlatTopology(EStage<GroupCommunicationMessage> senderStage,
Class<? extends Name<String>> groupName,
Class<? extends Name<String>> operatorName,
String driverId,
int numberOfTasks) |
Modifier and Type | Method and Description |
---|---|
void |
addTask(String taskId)
Add task with id 'taskId' to
the topology
|
int |
getNodeVersion(String taskId)
Get the version of the Task 'taskId'
that belongs to this topology
|
String |
getRootId()
Get the id of the root task
|
Configuration |
getTaskConfiguration(String taskId)
Get the topology portion of the Configuration
for the task 'taskId' that belongs to this
topology
|
void |
onFailedTask(String id)
Update state on receipt of FailedTask
event for task with id 'id'
|
void |
onReceiptOfMessage(GroupCommunicationMessage msg)
Update state on receipt of a message
from the tasks
|
void |
onRunningTask(String id)
Update state on receipt of RunningTask
event for task with id 'id'
|
void |
removeTask(String taskId)
Remove task with id 'taskId' from
the topology
|
void |
setOperatorSpecification(OperatorSpec spec)
Set operator specification of the operator
that is the owner of this topology instance
|
void |
setRootTask(String rootId)
Set task with id 'senderId' as
the root of this topology
|
public FlatTopology(EStage<GroupCommunicationMessage> senderStage, Class<? extends Name<String>> groupName, Class<? extends Name<String>> operatorName, String driverId, int numberOfTasks)
public void setRootTask(String rootId)
Topology
setRootTask
in interface Topology
public String getRootId()
Topology
public void setOperatorSpecification(OperatorSpec spec)
Topology
setOperatorSpecification
in interface Topology
public Configuration getTaskConfiguration(String taskId)
Topology
getTaskConfiguration
in interface Topology
public int getNodeVersion(String taskId)
Topology
getNodeVersion
in interface Topology
public void removeTask(String taskId)
Topology
removeTask
in interface Topology
public void addTask(String taskId)
Topology
public void onFailedTask(String id)
Topology
onFailedTask
in interface Topology
public void onRunningTask(String id)
Topology
onRunningTask
in interface Topology
public void onReceiptOfMessage(GroupCommunicationMessage msg)
Topology
onReceiptOfMessage
in interface Topology
Copyright © 2015 The Apache Software Foundation. All rights reserved.