public class LightBoltRunner extends LightComponent implements Runnable
This class is basically a Runnable
. Each runs in a dedicated thread, and
continuously loops waiting for input tuples.
componentId, streamDeclaration, subscribersPerStreamId, topologyContext
Constructor and Description |
---|
LightBoltRunner(LightTopology topology,
org.apache.storm.task.TopologyContext topologyContext,
LightBoltDispatcher boltDispatcher,
org.apache.storm.topology.IRichBolt boltInstance) |
Modifier and Type | Method and Description |
---|---|
void |
emit(String streamId,
List<Object> values,
LightTuple anchor)
Emit a tuple from a bolt.
|
org.apache.storm.task.OutputCollector |
getLightOutputCollector() |
void |
run() |
void |
setTickFrequency(Integer tickFrequencySec) |
addSubscriber, declareStream, getComponentId, getTopologyContext, publishStream
public LightBoltRunner(LightTopology topology, org.apache.storm.task.TopologyContext topologyContext, LightBoltDispatcher boltDispatcher, org.apache.storm.topology.IRichBolt boltInstance)
public org.apache.storm.task.OutputCollector getLightOutputCollector()
public void emit(String streamId, List<Object> values, LightTuple anchor)
streamId
- the stream identifiervalues
- the values to be emittedanchor
- the anchored tuple, if any.public void setTickFrequency(Integer tickFrequencySec)
Copyright © 2023. All rights reserved.