Name | Description | Type | Package | Framework |
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 | |
OpaquePartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |
PartitionedTransactionalSpoutExecutor | Class | backtype.storm.transactional.partitioned | Apache Storm | |