Uses of Interface
org.apache.storm.eventhubs.spout.IPartitionManager

Packages that use IPartitionManager

Package	Description
org.apache.storm.eventhubs.spout

Uses of IPartitionManager in org.apache.storm.eventhubs.spout

Classes in org.apache.storm.eventhubs.spout that implement IPartitionManager

Modifier and Type	Class and Description
class	PartitionManager
class	SimplePartitionManager A simple partition manager that does not re-send failed messages

Fields in org.apache.storm.eventhubs.spout with type parameters of type IPartitionManager

Modifier and Type	Field and Description
protected Map<String,IPartitionManager>	StaticPartitionCoordinator.partitionManagerMap
protected List<IPartitionManager>	StaticPartitionCoordinator.partitionManagers

Methods in org.apache.storm.eventhubs.spout that return IPartitionManager

Modifier and Type	Method and Description
IPartitionManager	IPartitionManagerFactory.create(EventHubSpoutConfig spoutConfig, String partitionId, IStateStore stateStore, IEventHubReceiver receiver)
IPartitionManager	StaticPartitionCoordinator.getPartitionManager(String partitionId)
IPartitionManager	IPartitionCoordinator.getPartitionManager(String partitionId)

Methods in org.apache.storm.eventhubs.spout that return types with arguments of type IPartitionManager

Modifier and Type	Method and Description
List<IPartitionManager>	StaticPartitionCoordinator.getMyPartitionManagers()
List<IPartitionManager>	IPartitionCoordinator.getMyPartitionManagers()