| Package | Description |
|---|---|
| backtype.storm.testing | |
| backtype.storm.topology.base | |
| backtype.storm.transactional | |
| backtype.storm.transactional.partitioned |
| Class and Description |
|---|
| IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
| IOpaquePartitionedTransactionalSpout.Coordinator |
| IOpaquePartitionedTransactionalSpout.Emitter |
| IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
| IPartitionedTransactionalSpout.Coordinator |
| IPartitionedTransactionalSpout.Emitter |
| Class and Description |
|---|
| IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
| IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
| Class and Description |
|---|
| IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
| IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
| Class and Description |
|---|
| IOpaquePartitionedTransactionalSpout
This defines a transactional spout which does *not* necessarily
replay the same batch every time it emits a batch for a transaction id.
|
| IOpaquePartitionedTransactionalSpout.Coordinator |
| IOpaquePartitionedTransactionalSpout.Emitter |
| IPartitionedTransactionalSpout
This interface defines a transactional spout that reads its tuples from a partitioned set of
brokers.
|
| IPartitionedTransactionalSpout.Coordinator |
| IPartitionedTransactionalSpout.Emitter |
Copyright © 2015. All rights reserved.