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

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

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

    Methods in org.apache.storm.eventhubs.trident with parameters of type TransactionAttempt
    Modifier and Type | Method and Description
    --- | ---
    `Map` | OpaqueTridentEventHubEmitter.`emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)`
    `void` | TransactionalTridentEventHubEmitter.`emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)`
    `Map<String,Object>` | TransactionalTridentEventHubEmitter.`emitPartitionBatchNew(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map<String,Object> meta)`

  - ### 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 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.

  - ### 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 and Description
    --- | ---
    `void` | ICommitterTridentSpout.Emitter.`commit(TransactionAttempt attempt)`
    `void` | OpaquePartitionedTridentSpoutExecutor.Emitter.`commit(TransactionAttempt attempt)`
    `void` | OpaquePartitionedTridentSpoutExecutor.Emitter.`emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)`
    `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.
    `M` | IOpaquePartitionedTridentSpout.Emitter.`emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, PartitionT partition, M lastPartitionMeta)` Emit a batch of tuples for a partition/transaction.
    `void` | IPartitionedTridentSpout.Emitter.`emitPartitionBatch(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.
    `X` | IPartitionedTridentSpout.Emitter.`emitPartitionBatchNew(TransactionAttempt tx, TridentCollector collector, PartitionT partition, X lastPartitionMeta)` Emit a batch of tuples for a partition/transaction that’s never been emitted before.
    `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)`
    `void` | BatchSpoutExecutor.BatchSpoutEmitter.`success(TransactionAttempt tx)`

Copyright © 2019 The Apache Software Foundation. All rights reserved.