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)