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 ITridentBatchBolt
public void execute(BatchInfo info, Tuple input)
execute
in interface ITridentBatchBolt
public void cleanup()
cleanup
in interface ITridentBatchBolt
public void declareOutputFields(OutputFieldsDeclarer declarer)
IComponent
Declare the output schema for all the streams of this topology.
declareOutputFields
in interface IComponent
declarer
- 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()
IComponent
Declare 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 IComponent
public void finishBatch(BatchInfo batchInfo)
finishBatch
in interface ITridentBatchBolt
public Object initBatchState(String batchGroup, Object batchId)
initBatchState
in interface ITridentBatchBolt
Copyright © 2022 The Apache Software Foundation. All rights reserved.