# 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
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentOpaqueSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  Emit a new batch.
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentTransactionalSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastPartitionMetaMap)`
  `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
  `void`
  KafkaTridentSpoutEmitter.`reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> currBatch)`
  Emit a batch that has already been emitted.
  `void`
  KafkaTridentTransactionalSpoutEmitter.`reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String,Object> partitionMeta)`
  Method parameters in org.apache.storm.kafka.spout.trident with type arguments of type KafkaTridentSpoutTopicPartition
  Modifier and Type
  Method
  Description
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentOpaqueSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentOpaqueSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  Emit a new batch.
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastBatchMetaMap)`
  Emit a new batch.
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentTransactionalSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastPartitionMetaMap)`
  `Map<KafkaTridentSpoutTopicPartition,Map<String,Object>>`
  KafkaTridentTransactionalSpoutEmitter.`emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition,Map<String,Object>> lastPartitionMetaMap)`
  `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)`