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.
|
int |
getNodeVersion(String taskId)
Get the version of the Task 'taskId'.
|
String |
getRootId()
Get the id of the root task.
|
Configuration |
getTaskConfiguration(String taskId)
Get the topology portion of the Configuration.
|
void |
onFailedTask(String id)
Update state on receipt of FailedTask.
|
void |
onReceiptOfMessage(GroupCommunicationMessage msg)
Update state on receipt of a message.
|
void |
onRunningTask(String id)
Update state on receipt of RunningTask.
|
void |
removeTask(String taskId)
Remove task with id 'taskId' from.
|
void |
setOperatorSpecification(OperatorSpec spec)
Set operator specification of the operator.
|
void |
setRootTask(String rootId)
Set task with id 'senderId' as.
|
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.