org.apache.storm.kafka

Class ZkCoordinator

java.lang.Object

org.apache.storm.kafka.ZkCoordinator

All Implemented Interfaces:

PartitionCoordinator

public class ZkCoordinator
extends Object
implements PartitionCoordinator

Constructor Summary

Constructors

Constructor and Description
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId)
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId, DynamicBrokersReader reader)

Method Summary

Modifier and Type	Method and Description
PartitionManager	getManager(Partition partition)
List<PartitionManager>	getMyManagedPartitions()
void	refresh()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZkCoordinator

public ZkCoordinator(DynamicPartitionConnections connections,
                     Map stormConf,
                     SpoutConfig spoutConfig,
                     ZkState state,
                     int taskIndex,
                     int totalTasks,
                     int taskId,
                     String topologyInstanceId)

ZkCoordinator

public ZkCoordinator(DynamicPartitionConnections connections,
                     Map stormConf,
                     SpoutConfig spoutConfig,
                     ZkState state,
                     int taskIndex,
                     int totalTasks,
                     int taskId,
                     String topologyInstanceId,
                     DynamicBrokersReader reader)

Method Detail

getMyManagedPartitions

public List<PartitionManager> getMyManagedPartitions()

Specified by:

getMyManagedPartitions in interface PartitionCoordinator

refresh

public void refresh()

Specified by:

refresh in interface PartitionCoordinator

getManager

public PartitionManager getManager(Partition partition)

Specified by:

getManager in interface PartitionCoordinator