Uses of Class
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition

Packages that use KafkaTridentSpoutTopicPartition

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

Uses of KafkaTridentSpoutTopicPartition in org.apache.storm.kafka.spout.trident

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

Modifier and Type	Method and Description
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutOpaque.getEmitter(Map conf, TopologyContext context)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getOrderedPartitions(List<Map<String,Object>> allPartitionInfo) Computes ordered list of topic-partitions for this task taking into consideration that topic-partitions for this task must be assigned to the Kafka consumer running on this task.
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfo)

Methods in org.apache.storm.kafka.spout.trident with parameters of type KafkaTridentSpoutTopicPartition

Modifier and Type	Method and Description
Map<String,Object>	KafkaTridentSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> lastBatch)

Method parameters in org.apache.storm.kafka.spout.trident with type arguments of type KafkaTridentSpoutTopicPartition

Modifier and Type	Method and Description
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfo)
void	KafkaTridentSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)