## 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)` |