## Uses of Class
org.apache.storm.trident.topology.TransactionAttempt

- Packages that use TransactionAttempt
  Package | Description
  --- | ---
  org.apache.storm.kafka.spout.trident |
  org.apache.storm.trident.spout |

- - ### Uses of TransactionAttempt in org.apache.storm.kafka.spout.trident

    Methods in org.apache.storm.kafka.spout.trident with parameters of type TransactionAttempt
    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)` |
    `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)` |

  - ### Uses of TransactionAttempt in org.apache.storm.trident.spout

    Methods in org.apache.storm.trident.spout with parameters of type TransactionAttempt
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | ICommitterTridentSpout.Emitter.`commit​(TransactionAttempt attempt)` |
    `void` | OpaquePartitionedTridentSpoutExecutor.Emitter.`commit​(TransactionAttempt attempt)` |
    `void` | BatchSpoutExecutor.BatchSpoutEmitter.`emitBatch​(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)` |
    `void` | ITridentSpout.Emitter.`emitBatch​(TransactionAttempt tx, X coordinatorMeta, TridentCollector collector)` | Emit a batch for the specified transaction attempt and metadata for the transaction.
    `void` | OpaquePartitionedTridentSpoutExecutor.Emitter.`emitBatch​(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)` |
    `Map<PartitionT,​M>` | IOpaquePartitionedTridentSpout.Emitter.`emitBatchNew​(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,​M> lastBatchMetaMap)` | Emit a batch of tuples for a list of partitions/transactions.
    `Map<PartitionT,​X>` | IPartitionedTridentSpout.Emitter.`emitBatchNew​(TransactionAttempt tx, TridentCollector collector, Set<PartitionT> partitions, Map<PartitionT,​X> lastPartitionMetaMap)` | Emit a batch of tuples for the partitions that's never been emitted before.
    `void` | IPartitionedTridentSpout.Emitter.`reEmitPartitionBatch​(TransactionAttempt tx, TridentCollector collector, PartitionT partition, X partitionMeta)` | Emit a batch of tuples for a partition/transaction that has been emitted before, using the metadata created when it was first emitted.
    `void` | BatchSpoutExecutor.BatchSpoutEmitter.`success​(TransactionAttempt tx)` |
    `void` | ITridentSpout.Emitter.`success​(TransactionAttempt tx)` | This attempt committed successfully, so all state for this commit and before can be safely cleaned up.
    `void` | OpaquePartitionedTridentSpoutExecutor.Emitter.`success​(TransactionAttempt tx)` |