public interface Topology
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 senderId)
Set task with id 'senderId' as
the root of this topology
|
int getNodeVersion(String taskId)
taskId
- void 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 © 2015 The Apache Software Foundation. All rights reserved.