Uses of Class
storm.kafka.trident.GlobalPartitionInformation

Packages that use GlobalPartitionInformation
storm.kafka   
storm.kafka.trident   
 

Uses of GlobalPartitionInformation in storm.kafka
 

Methods in storm.kafka that return GlobalPartitionInformation
 GlobalPartitionInformation DynamicBrokersReader.getBrokerInfo()
          Get all partitions with their current leaders
 GlobalPartitionInformation StaticHosts.getPartitionInformation()
           
 

Methods in storm.kafka with parameters of type GlobalPartitionInformation
static List<Partition> KafkaUtils.calculatePartitionsForTask(GlobalPartitionInformation partitionInformation, int totalTasks, int taskIndex)
           
 

Constructors in storm.kafka with parameters of type GlobalPartitionInformation
StaticHosts(GlobalPartitionInformation partitionInformation)
           
 

Uses of GlobalPartitionInformation in storm.kafka.trident
 

Methods in storm.kafka.trident that return GlobalPartitionInformation
 GlobalPartitionInformation ZkBrokerReader.getCurrentBrokers()
           
 GlobalPartitionInformation StaticBrokerReader.getCurrentBrokers()
           
 GlobalPartitionInformation IBrokerReader.getCurrentBrokers()
           
 

Methods in storm.kafka.trident that return types with arguments of type GlobalPartitionInformation
 IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> TridentKafkaEmitter.asOpaqueEmitter()
           
 IOpaquePartitionedTridentSpout.Emitter<GlobalPartitionInformation,Partition,Map> OpaqueTridentKafkaSpout.getEmitter(Map conf, TopologyContext context)
           
 

Constructors in storm.kafka.trident with parameters of type GlobalPartitionInformation
StaticBrokerReader(GlobalPartitionInformation partitionInformation)
           
 



Copyright © 2015 The Apache Software Foundation. All Rights Reserved.