| Package | Description |
|---|---|
| backtype.storm.transactional | |
| backtype.storm.transactional.partitioned |
| Modifier and Type | Method and Description |
|---|---|
ITransactionalSpout.Coordinator<T> |
ITransactionalSpout.getCoordinator(Map conf,
TopologyContext context)
The coordinator for a TransactionalSpout runs in a single thread and indicates when batches
of tuples should be emitted and when transactions should commit.
|
| Modifier and Type | Class and Description |
|---|---|
class |
OpaquePartitionedTransactionalSpoutExecutor.Coordinator |
| Modifier and Type | Method and Description |
|---|---|
ITransactionalSpout.Coordinator |
PartitionedTransactionalSpoutExecutor.getCoordinator(Map conf,
TopologyContext context) |
ITransactionalSpout.Coordinator<Object> |
OpaquePartitionedTransactionalSpoutExecutor.getCoordinator(Map conf,
TopologyContext context) |
Copyright © 2015. All rights reserved.