Name | Description | Type | Package | Framework |
ICommitterTransactionalSpout | Interface | backtype.storm.transactional | Apache Storm | |
ICommitterTransactionalSpout .Emitter | Interface | backtype.storm.transactional.ICommitterTransactionalSpout | Apache Storm | |
IOpaquePartitionedTransactionalSpout | This defines a transactional spout which does *not* necessarily replay the same batch every time it emits a batch for a transaction id. | Interface | backtype.storm.transactional.partitioned | Apache Storm |
IOpaquePartitionedTransactionalSpout .Coordinator | Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction). | Interface | backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout | Apache Storm |
IOpaquePartitionedTransactionalSpout .Emitter | Interface | backtype.storm.transactional.partitioned.IOpaquePartitionedTransactionalSpout | Apache Storm | |
IPartitionedTransactionalSpout | This interface defines a transactional spout that reads its tuples from a partitioned set of brokers. | Interface | backtype.storm.transactional.partitioned | Apache Storm |
IPartitionedTransactionalSpout .Coordinator | Returns true if its ok to emit start a new transaction, false otherwise (will skip this transaction). | Interface | backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout | Apache Storm |
IPartitionedTransactionalSpout .Emitter | Interface | backtype.storm.transactional.partitioned.IPartitionedTransactionalSpout | Apache Storm | |
ITransactionalSpout | Interface | backtype.storm.transactional | Apache Storm | |
ITransactionalSpout .Coordinator | Release any resources from this coordinator. | Interface | backtype.storm.transactional.ITransactionalSpout | Apache Storm |
ITransactionalSpout .Emitter | Any state for transactions prior to the provided transaction id can be safely cleaned up, so this method should clean up that state. | Interface | backtype.storm.transactional.ITransactionalSpout | Apache Storm |
OpaquePartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |
PartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |
RotatingTransactionalState | A map from txid to a value. | Class | backtype.storm.transactional.state | Apache Storm |
RotatingTransactionalState .StateInitializer | Interface | backtype.storm.transactional.state.RotatingTransactionalState | Apache Storm | |
TestTransactionalState | Facilitates testing of non-public methods in the parent class. | Class | backtype.storm.transactional.state | Apache Storm |
TransactionalSpoutBatchExecutor | Class | backtype.storm.transactional | Apache Storm | |
TransactionalSpoutCoordinator | Class | backtype.storm.transactional | Apache Storm | |
TransactionalState | Class | backtype.storm.transactional.state | Apache Storm | |
TransactionalTopologyBuilder | Trident subsumes the functionality provided by transactional topologies, so this class is deprecated. | Class | backtype.storm.transactional | Apache Storm |
TransactionAttempt | Class | backtype.storm.transactional | Apache Storm | |