Uses of Class
org.apache.storm.trident.topology.TransactionAttempt
Packages that use TransactionAttempt
-
Uses of TransactionAttempt in org.apache.storm.kafka.spout.trident
Methods in org.apache.storm.kafka.spout.trident with parameters of type TransactionAttemptModifier and TypeMethodDescriptionKafkaTridentOpaqueSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) KafkaTridentSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastBatchMetaMap) Emit a new batch.KafkaTridentTransactionalSpoutEmitter.emitBatchNew(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions, Map<KafkaTridentSpoutTopicPartition, Map<String, Object>> lastPartitionMetaMap) voidKafkaTridentSpoutEmitter.reEmitPartitionBatch(TransactionAttempt tx, TridentCollector collector, KafkaTridentSpoutTopicPartition currBatchPartition, Map<String, Object> currBatch) Emit a batch that has already been emitted.voidKafkaTridentTransactionalSpoutEmitter.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 TransactionAttemptModifier and TypeMethodDescriptionvoidICommitterTridentSpout.Emitter.commit(TransactionAttempt attempt) voidOpaquePartitionedTridentSpoutExecutor.Emitter.commit(TransactionAttempt attempt) voidBatchSpoutExecutor.BatchSpoutEmitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) voidITridentSpout.Emitter.emitBatch(TransactionAttempt tx, X coordinatorMeta, TridentCollector collector) Emit a batch for the specified transaction attempt and metadata for the transaction.voidOpaquePartitionedTridentSpoutExecutor.Emitter.emitBatch(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector) 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.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.voidIPartitionedTridentSpout.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.voidBatchSpoutExecutor.BatchSpoutEmitter.success(TransactionAttempt tx) voidITridentSpout.Emitter.success(TransactionAttempt tx) This attempt committed successfully, so all state for this commit and before can be safely cleaned up.voidOpaquePartitionedTridentSpoutExecutor.Emitter.success(TransactionAttempt tx)