org.apache.storm.kafka

Class ZkCoordinator

java.lang.Object

org.apache.storm.kafka.ZkCoordinator

All Implemented Interfaces:

PartitionCoordinator

public class ZkCoordinator
extends java.lang.Object
implements PartitionCoordinator

Constructor Summary

Constructors

Constructor and Description
ZkCoordinator(DynamicPartitionConnections connections, java.util.Map<java.lang.String,java.lang.Object> stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, java.lang.String topologyInstanceId)
ZkCoordinator(DynamicPartitionConnections connections, java.util.Map<java.lang.String,java.lang.Object> stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, java.lang.String topologyInstanceId, DynamicBrokersReader reader)

Method Summary

Modifier and Type	Method and Description
PartitionManager	getManager(Partition partition)
java.util.List<PartitionManager>	getMyManagedPartitions()
int	getTaskIndex()
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,
                     java.util.Map<java.lang.String,java.lang.Object> stormConf,
                     SpoutConfig spoutConfig,
                     ZkState state,
                     int taskIndex,
                     int totalTasks,
                     java.lang.String topologyInstanceId)

ZkCoordinator

public ZkCoordinator(DynamicPartitionConnections connections,
                     java.util.Map<java.lang.String,java.lang.Object> stormConf,
                     SpoutConfig spoutConfig,
                     ZkState state,
                     int taskIndex,
                     int totalTasks,
                     java.lang.String topologyInstanceId,
                     DynamicBrokersReader reader)

Method Detail

getTaskIndex

public int getTaskIndex()

getMyManagedPartitions

public java.util.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