Uses of Class
org.apache.storm.kafka.PartitionManager

Packages that use PartitionManager

Package	Description
org.apache.storm.kafka

Uses of PartitionManager in org.apache.storm.kafka

Methods in org.apache.storm.kafka that return PartitionManager

Modifier and Type	Method and Description
PartitionManager	ZkCoordinator.getManager(Partition partition)
PartitionManager	StaticCoordinator.getManager(Partition partition)
PartitionManager	PartitionCoordinator.getManager(Partition partition)

Methods in org.apache.storm.kafka that return types with arguments of type PartitionManager

Modifier and Type	Method and Description
List<PartitionManager>	ZkCoordinator.getMyManagedPartitions()
List<PartitionManager>	StaticCoordinator.getMyManagedPartitions()
List<PartitionManager>	PartitionCoordinator.getMyManagedPartitions()

Constructors in org.apache.storm.kafka with parameters of type PartitionManager

Constructor and Description
PartitionManager(DynamicPartitionConnections connections, String topologyInstanceId, ZkState state, Map stormConf, SpoutConfig spoutConfig, Partition id, PartitionManager previousManager)