Uses of Class
org.apache.storm.transactional.TransactionAttempt

Packages that use TransactionAttempt

Package	Description
org.apache.storm.starter
org.apache.storm.testing
org.apache.storm.transactional
org.apache.storm.transactional.partitioned

Uses of TransactionAttempt in org.apache.storm.starter

Methods in org.apache.storm.starter with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	TransactionalWords.KeyedCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)
void	TransactionalWords.BucketCountUpdater.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)
void	TransactionalGlobalCount.UpdateGlobalCount.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt attempt)

Uses of TransactionAttempt in org.apache.storm.testing

Methods in org.apache.storm.testing with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	CountingCommitBolt.prepare(Map conf, TopologyContext context, BatchOutputCollector collector, TransactionAttempt id)

Uses of TransactionAttempt in org.apache.storm.transactional

Methods in org.apache.storm.transactional with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	ICommitterTransactionalSpout.Emitter.commit(TransactionAttempt attempt)
void	ITransactionalSpout.Emitter.emitBatch(TransactionAttempt tx, X coordinatorMeta, BatchOutputCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.

Uses of TransactionAttempt in org.apache.storm.transactional.partitioned

Methods in org.apache.storm.transactional.partitioned with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	OpaquePartitionedTransactionalSpoutExecutor.Emitter.commit(TransactionAttempt attempt)
void	OpaquePartitionedTransactionalSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, BatchOutputCollector collector)
void	IPartitionedTransactionalSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int 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	IOpaquePartitionedTransactionalSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction.
X	IPartitionedTransactionalSpout.Emitter.emitPartitionBatchNew(TransactionAttempt tx, BatchOutputCollector collector, int partition, X lastPartitionMeta) Emit a batch of tuples for a partition/transaction that’s never been emitted before.