storm.kafka
Class ZkCoordinator
java.lang.Object
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public static final org.slf4j.Logger LOG
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)
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 © 2016 The Apache Software Foundation. All Rights Reserved.