storm.kafka
Class ZkCoordinator

java.lang.Object
  extended by storm.kafka.ZkCoordinator
All Implemented Interfaces:
PartitionCoordinator

public class ZkCoordinator
extends Object
implements PartitionCoordinator


Field Summary
static org.slf4j.Logger LOG
           
 
Constructor Summary
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, String topologyInstanceId)
           
ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, String topologyInstanceId, DynamicBrokersReader reader)
           
 
Method Summary
 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
 

Field Detail

LOG

public static final org.slf4j.Logger LOG
Constructor Detail

ZkCoordinator

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

ZkCoordinator

public ZkCoordinator(DynamicPartitionConnections connections,
                     Map stormConf,
                     SpoutConfig spoutConfig,
                     ZkState state,
                     int taskIndex,
                     int totalTasks,
                     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


Copyright © 2015 The Apache Software Foundation. All Rights Reserved.