org.apache.storm.kafka

Class StaticCoordinator

java.lang.Object

org.apache.storm.kafka.StaticCoordinator

All Implemented Interfaces:

PartitionCoordinator

public class StaticCoordinator
extends Object
implements PartitionCoordinator

Constructor Summary

Constructors

Constructor and Description
StaticCoordinator(DynamicPartitionConnections connections, Map stormConf, SpoutConfig config, ZkState state, int taskIndex, int totalTasks, int taskId, String topologyInstanceId)

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

StaticCoordinator

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

Method Detail

getMyManagedPartitions

public List<PartitionManager> getMyManagedPartitions()

Specified by:

getMyManagedPartitions in interface PartitionCoordinator

getManager

public PartitionManager getManager(Partition partition)

Specified by:

getManager in interface PartitionCoordinator

refresh

public void refresh()

Specified by:

refresh in interface PartitionCoordinator