org.apache.storm.kafka

Class StaticCoordinator

java.lang.Object

org.apache.storm.kafka.StaticCoordinator

All Implemented Interfaces:

PartitionCoordinator

public class StaticCoordinator
extends java.lang.Object
implements PartitionCoordinator

Constructor Summary

Constructors

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

Method Summary

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

Method Detail

getMyManagedPartitions

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