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