Uses of Class
org.apache.storm.trident.topology.TransactionAttempt

Packages that use TransactionAttempt

Package	Description
org.apache.storm.eventhubs.trident
org.apache.storm.kafka.spout.trident
org.apache.storm.trident.spout

Uses of TransactionAttempt in org.apache.storm.eventhubs.trident

Methods in org.apache.storm.eventhubs.trident with parameters of type TransactionAttempt

Modifier and Type	Method and Description
void	TransactionalTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)
Map	OpaqueTridentEventHubEmitter.emitPartitionBatch(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)
Map	TransactionalTridentEventHubEmitter.emitPartitionBatchNew(TransactionAttempt attempt, TridentCollector collector, Partition partition, Map meta)

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 and Description
Map<String,Object>	KafkaTridentSpoutEmitter.emitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String,Object> lastBatch)

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 and Description
void	OpaquePartitionedTridentSpoutExecutor.Emitter.commit(TransactionAttempt attempt)
void	ICommitterTridentSpout.Emitter.commit(TransactionAttempt attempt)
void	OpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
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.
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	OpaquePartitionedTridentSpoutExecutor.Emitter.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	BatchSpoutExecutor.BatchSpoutEmitter.success(TransactionAttempt tx)