public class FeederBatchSpout extends Object implements ITridentSpout, IFeeder
| Modifier and Type | Class and Description |
|---|---|
class |
FeederBatchSpout.FeederCoordinator |
class |
FeederBatchSpout.FeederEmitter |
ITridentSpout.BatchCoordinator<X>, ITridentSpout.Emitter<X>| Constructor and Description |
|---|
FeederBatchSpout(List<String> fields) |
| Modifier and Type | Method and Description |
|---|---|
void |
feed(Object tuples) |
Map |
getComponentConfiguration() |
ITridentSpout.BatchCoordinator |
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.Emitter |
getEmitter(String txStateId,
Map conf,
TopologyContext context)
The emitter for a TransactionalSpout runs as many tasks across the cluster.
|
Fields |
getOutputFields() |
void |
setWaitToEmit(boolean trueIfWait) |
public void setWaitToEmit(boolean trueIfWait)
public Map getComponentConfiguration()
getComponentConfiguration in interface ITridentSpoutpublic Fields getOutputFields()
getOutputFields in interface ITridentSpoutpublic ITridentSpout.BatchCoordinator getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpoutgetCoordinator in interface ITridentSpoutpublic ITridentSpout.Emitter getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpoutgetEmitter in interface ITridentSpoutCopyright © 2015. All rights reserved.