public class TaskCoordinator extends java.lang.Object implements GroupListener<WorkerNode>, WorkItemListener
GroupListener.GroupEvent
Constructor and Description |
---|
TaskCoordinator(TaskContext context,
WorkItemRepository repository,
BalancingPolicy balancingPolicy,
org.apache.curator.framework.CuratorFramework curator) |
Modifier and Type | Method and Description |
---|---|
void |
groupEvent(Group<WorkerNode> group,
GroupListener.GroupEvent event) |
void |
partitionUpdated()
Call whenever the partitions are updated.
|
void |
rebalance()
Re-balances all available
WorkItem items to all available Workers. |
void |
start() |
void |
stop() |
public TaskCoordinator(TaskContext context, WorkItemRepository repository, BalancingPolicy balancingPolicy, org.apache.curator.framework.CuratorFramework curator)
public void start()
public void stop()
public void groupEvent(Group<WorkerNode> group, GroupListener.GroupEvent event)
groupEvent
in interface GroupListener<WorkerNode>
public void partitionUpdated()
WorkItemListener
partitionUpdated
in interface WorkItemListener
public void rebalance()
WorkItem
items to all available Workers.Copyright © 2014 Red Hat. All Rights Reserved.