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