public class RichSpoutBatchExecutor extends Object implements ITridentSpout
ITridentSpout.BatchCoordinator<X>, ITridentSpout.Emitter<X>
Modifier and Type | Field and Description |
---|---|
static String |
MAX_BATCH_SIZE_CONF |
Constructor and Description |
---|
RichSpoutBatchExecutor(IRichSpout 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 static final String MAX_BATCH_SIZE_CONF
public RichSpoutBatchExecutor(IRichSpout spout)
public Map getComponentConfiguration()
getComponentConfiguration
in interface ITridentSpout
public Fields getOutputFields()
getOutputFields
in interface ITridentSpout
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
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.