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

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

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