public class TridentSpoutExecutor extends Object implements ITridentBatchBolt
| Modifier and Type | Field and Description |
|---|---|
static String |
ID_FIELD |
static org.slf4j.Logger |
LOG |
| Constructor and Description |
|---|
TridentSpoutExecutor(String txStateId,
String streamName,
ITridentSpout<Object> spout) |
| Modifier and Type | Method and Description |
|---|---|
void |
cleanup() |
void |
declareOutputFields(OutputFieldsDeclarer declarer)
Declare the output schema for all the streams of this topology.
|
void |
execute(BatchInfo info,
Tuple input) |
void |
finishBatch(BatchInfo batchInfo) |
Map<String,Object> |
getComponentConfiguration()
Declare configuration specific to this component.
|
Object |
initBatchState(String batchGroup,
Object batchId) |
void |
prepare(Map<String,Object> conf,
TopologyContext context,
BatchOutputCollector collector) |
public static final String ID_FIELD
public static final org.slf4j.Logger LOG
public TridentSpoutExecutor(String txStateId, String streamName, ITridentSpout<Object> spout)
public void prepare(Map<String,Object> conf, TopologyContext context, BatchOutputCollector collector)
prepare in interface ITridentBatchBoltpublic void execute(BatchInfo info, Tuple input)
execute in interface ITridentBatchBoltpublic void cleanup()
cleanup in interface ITridentBatchBoltpublic void declareOutputFields(OutputFieldsDeclarer declarer)
IComponentDeclare the output schema for all the streams of this topology.
declareOutputFields in interface IComponentdeclarer - this is used to declare output stream ids, output fields, and whether or not each output stream is a direct streampublic Map<String,Object> getComponentConfiguration()
IComponentDeclare configuration specific to this component. Only a subset of the “topology.*” configs can be overridden. The component configuration can be further overridden when constructing the topology using TopologyBuilder
getComponentConfiguration in interface IComponentpublic void finishBatch(BatchInfo batchInfo)
finishBatch in interface ITridentBatchBoltpublic Object initBatchState(String batchGroup, Object batchId)
initBatchState in interface ITridentBatchBoltCopyright © 2021 The Apache Software Foundation. All rights reserved.