Package | Description |
---|---|
storm.trident.spout | |
storm.trident.testing |
Modifier and Type | Class and Description |
---|---|
static class |
BatchSpoutExecutor.EmptyCoordinator |
class |
OpaquePartitionedTridentSpoutExecutor.Coordinator |
Modifier and Type | Method and Description |
---|---|
ITridentSpout.BatchCoordinator |
RichSpoutBatchExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator |
PartitionedTridentSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator<Object> |
OpaquePartitionedTridentSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator<T> |
ITridentSpout.getCoordinator(String txStateId,
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.
|
ITridentSpout.BatchCoordinator |
BatchSpoutExecutor.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
Modifier and Type | Class and Description |
---|---|
class |
FeederBatchSpout.FeederCoordinator |
Modifier and Type | Method and Description |
---|---|
ITridentSpout.BatchCoordinator |
FeederCommitterBatchSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
ITridentSpout.BatchCoordinator |
FeederBatchSpout.getCoordinator(String txStateId,
Map conf,
TopologyContext context) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.