public class ZkCoordinator extends Object implements PartitionCoordinator
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
PartitionManager |
getManager(Partition partition) |
List<PartitionManager> |
getMyManagedPartitions() |
void |
refresh() |
public ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, String topologyInstanceId)
public ZkCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig spoutConfig, ZkState state, int taskIndex, int totalTasks, String topologyInstanceId, DynamicBrokersReader reader)
public List<PartitionManager> getMyManagedPartitions()
getMyManagedPartitions
in interface PartitionCoordinator
public void refresh()
refresh
in interface PartitionCoordinator
public PartitionManager getManager(Partition partition)
getManager
in interface PartitionCoordinator
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.