Uses of Class
org.apache.storm.kafka.trident.GlobalPartitionInformation

Packages that use GlobalPartitionInformation

Package	Description
org.apache.storm.kafka
org.apache.storm.kafka.trident

Uses of GlobalPartitionInformation in org.apache.storm.kafka

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

Modifier and Type	Method and Description
GlobalPartitionInformation	StaticHosts.getPartitionInformation()

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

Modifier and Type	Method and Description
List<GlobalPartitionInformation>	DynamicBrokersReader.getBrokerInfo() Get all partitions with their current leaders

Method parameters in org.apache.storm.kafka with type arguments of type GlobalPartitionInformation

Modifier and Type	Method and Description
static List<Partition>	KafkaUtils.calculatePartitionsForTask(List<GlobalPartitionInformation> partitons, int totalTasks, int taskIndex, int taskId)

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

Constructor and Description
StaticHosts(GlobalPartitionInformation partitionInformation)

Uses of GlobalPartitionInformation in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that return GlobalPartitionInformation

Modifier and Type	Method and Description
GlobalPartitionInformation	ZkBrokerReader.getBrokerForTopic(String topic)
GlobalPartitionInformation	StaticBrokerReader.getBrokerForTopic(String topic)
GlobalPartitionInformation	IBrokerReader.getBrokerForTopic(String topic)

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

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	TridentKafkaEmitter.asOpaqueEmitter()
List<GlobalPartitionInformation>	ZkBrokerReader.getAllBrokers()
List<GlobalPartitionInformation>	StaticBrokerReader.getAllBrokers()
List<GlobalPartitionInformation>	IBrokerReader.getAllBrokers()
IOpaquePartitionedTridentSpout.Emitter<List<GlobalPartitionInformation>,Partition,Map>	OpaqueTridentKafkaSpout.getEmitter(Map conf, TopologyContext context) Deprecated.

Constructors in org.apache.storm.kafka.trident with parameters of type GlobalPartitionInformation

Constructor and Description
StaticBrokerReader(String topic, GlobalPartitionInformation partitionInformation)