| Package | Description |
|---|---|
| org.apache.storm.testing | |
| org.apache.storm.topology.base | |
| org.apache.storm.transactional | |
| org.apache.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 © 2019 The Apache Software Foundation. All Rights Reserved.