Package | Description |
---|---|
storm.kafka |
Modifier and Type | Method and Description |
---|---|
PartitionManager |
ZkCoordinator.getManager(Partition partition) |
PartitionManager |
StaticCoordinator.getManager(Partition partition) |
PartitionManager |
PartitionCoordinator.getManager(Partition partition) |
Modifier and Type | Method and Description |
---|---|
List<PartitionManager> |
ZkCoordinator.getMyManagedPartitions() |
List<PartitionManager> |
StaticCoordinator.getMyManagedPartitions() |
List<PartitionManager> |
PartitionCoordinator.getMyManagedPartitions() |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.