public interface 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 senderId)
Set task with id 'senderId' as.
|
int getNodeVersion(String taskId)
taskId
- boolean isRootPresent()
true
if root has been added, false
otherwisevoid setRootTask(String senderId)
senderId
- void removeTask(String taskId)
taskId
- void onRunningTask(String id)
id
- void onFailedTask(String id)
id
- void setOperatorSpecification(OperatorSpec spec)
spec
- Configuration getTaskConfiguration(String taskId)
taskId
- void onReceiptOfMessage(GroupCommunicationMessage msg)
msg
- Copyright © 2017 The Apache Software Foundation. All rights reserved.