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	Description
IOpaquePartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutOpaque.getEmitter(Map<String,Object> conf, TopologyContext context)
IPartitionedTridentSpout.Emitter<List<Map<String,Object>>,KafkaTridentSpoutTopicPartition,Map<String,Object>>	KafkaTridentSpoutTransactional.getEmitter(Map<String,Object> conf, TopologyContext context)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentOpaqueSpoutEmitter.getOrderedPartitions(List<Map<String,Object>> allPartitionInfo)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getOrderedPartitions(List<Map<String,Object>> allPartitionInfo)	Get the input partitions in sorted order.
List<KafkaTridentSpoutTopicPartition>	KafkaTridentTransactionalSpoutEmitter.getOrderedPartitions(List<Map<String,Object>> allPartitionInfo)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentOpaqueSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted)	Get the partitions that should be handled by this task.

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

Modifier and Type	Method	Description
Map<String,Object>	KafkaTridentOpaqueSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> lastPartitionMeta)
void	KafkaTridentTransactionalSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> partitionMeta)
Map<String,Object>	KafkaTridentSpoutEmitter.emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> lastBatch)	Emit a new batch.
Map<String,Object>	KafkaTridentTransactionalSpoutEmitter.emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> lastPartitionMeta)
void	KafkaTridentSpoutEmitter.reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> currBatch)	Emit a batch that has already been emitted.

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

Modifier and Type	Method	Description
List<KafkaTridentSpoutTopicPartition>	KafkaTridentOpaqueSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted)
List<KafkaTridentSpoutTopicPartition>	KafkaTridentSpoutEmitter.getPartitionsForTask(int taskId, int numTasks, List<KafkaTridentSpoutTopicPartition> allPartitionInfoSorted)	Get the partitions that should be handled by this task.
void	KafkaTridentOpaqueSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)
void	KafkaTridentSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)	Prepare the emitter to handle the input partitions.
void	KafkaTridentTransactionalSpoutEmitter.refreshPartitions(List<KafkaTridentSpoutTopicPartition> partitionResponsibilities)