Uses of Class
org.apache.storm.trident.topology.TransactionAttempt
-
Uses of TransactionAttempt in org.apache.storm.kafka.spout.trident
Modifier and TypeMethodDescriptionKafkaTridentOpaqueSpoutEmitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> lastPartitionMeta) void
KafkaTridentTransactionalSpoutEmitter.emitPartitionBatch
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition partition, Map<String, Object> partitionMeta) KafkaTridentSpoutEmitter.emitPartitionBatchNew
(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> lastBatch) Emit a new batch.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
Modifier and TypeMethodDescriptionvoid
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) 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.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)