Uses of Class
backtype.storm.transactional.TransactionAttempt

Packages that use TransactionAttempt

Package	Description
backtype.storm.testing
backtype.storm.transactional
backtype.storm.transactional.partitioned

Uses of TransactionAttempt in backtype.storm.testing

Methods in backtype.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 backtype.storm.transactional

Methods in backtype.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 backtype.storm.transactional.partitioned

Methods in backtype.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.