Uses of Class
storm.trident.topology.TransactionAttempt

Packages that use TransactionAttempt

Package	Description
storm.trident.spout
storm.trident.testing

Uses of TransactionAttempt in storm.trident.spout

Methods in storm.trident.spout with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	OpaquePartitionedTridentSpoutExecutor.Emitter.commit(TransactionAttempt attempt)
void	ICommitterTridentSpout.Emitter.commit(TransactionAttempt attempt)
void	BatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
void	OpaquePartitionedTridentSpoutExecutor.Emitter.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, Partition partition, M lastPartitionMeta) Emit a batch of tuples for a partition/transaction.
void	IPartitionedTridentSpout.Emitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, Partition 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, Partition 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	BatchSpoutExecutor.BatchSpoutEmitter.success(TransactionAttempt tx)
void	OpaquePartitionedTridentSpoutExecutor.Emitter.success(TransactionAttempt tx)

Uses of TransactionAttempt in storm.trident.testing

Methods in storm.trident.testing with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	FeederBatchSpout.FeederEmitter.emitBatch(TransactionAttempt tx, Map<Integer,List<List<Object>>> coordinatorMeta, TridentCollector collector)
void	FeederBatchSpout.FeederEmitter.success(TransactionAttempt tx)