public final class FlatTopology extends Object implements Topology
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.
|
boolean |
isRootPresent()
Check whether the root node has been added or not.
|
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 void setRootTask(String rootId)
Topology
setRootTask
in interface Topology
public String getRootId()
Topology
public boolean isRootPresent()
Topology
isRootPresent
in interface Topology
true
if root has been added, false
otherwisepublic 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 © 2017 The Apache Software Foundation. All rights reserved.