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 | |