org.apache.storm.eventhubs.spout

Interface IPartitionCoordinator

All Known Implementing Classes:

StaticPartitionCoordinator

public interface IPartitionCoordinator

Method Summary

Modifier and Type	Method and Description
List<IPartitionManager>	getMyPartitionManagers()
IPartitionManager	getPartitionManager(String partitionId)

Method Detail

getMyPartitionManagers

List<IPartitionManager> getMyPartitionManagers()

getPartitionManager

IPartitionManager getPartitionManager(String partitionId)