public class BatchSpoutExecutor extends Object implements ITridentSpout
Modifier and Type | Class and Description |
---|---|
class |
BatchSpoutExecutor.BatchSpoutEmitter |
static class |
BatchSpoutExecutor.EmptyCoordinator |
ITridentSpout.BatchCoordinator<X>, ITridentSpout.Emitter<X>
Constructor and Description |
---|
BatchSpoutExecutor(IBatchSpout spout) |
Modifier and Type | Method and Description |
---|---|
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() |
public BatchSpoutExecutor(IBatchSpout spout)
public ITridentSpout.BatchCoordinator getCoordinator(String txStateId, Map conf, TopologyContext context)
ITridentSpout
getCoordinator
in interface ITridentSpout
public ITridentSpout.Emitter getEmitter(String txStateId, Map conf, TopologyContext context)
ITridentSpout
getEmitter
in interface ITridentSpout
public Map getComponentConfiguration()
getComponentConfiguration
in interface ITridentSpout
public Fields getOutputFields()
getOutputFields
in interface ITridentSpout
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.