public class LightBoltDispatcher extends LightComponent
It contains a single input tuple queue where all the tuple from source spouts/bolts push their emitted tuple. This queue will be consumed by the one or several instance LightBoltRunner.
componentId, streamDeclaration, subscribersPerStreamId, topologyContext
Constructor and Description |
---|
LightBoltDispatcher(LightTopology topology,
org.apache.storm.task.TopologyContext topologyContext,
String componentId,
org.apache.storm.topology.IRichBolt bolt,
int executors) |
Modifier and Type | Method and Description |
---|---|
org.apache.storm.topology.IRichBolt |
getClonedBoltInstance()
This method re-serialize a fresh new tuple instance from the
original bolt.
|
String |
getComponentId() |
int |
getExecutors() |
LinkedBlockingQueue<LightTuple> |
getInputQueue() |
addSubscriber, declareStream, getTopologyContext, publishStream
public LightBoltDispatcher(LightTopology topology, org.apache.storm.task.TopologyContext topologyContext, String componentId, org.apache.storm.topology.IRichBolt bolt, int executors)
topology
- topologytopologyContext
- topologyContextcomponentId
- componentIdbolt
- boltexecutors
- executorspublic LinkedBlockingQueue<LightTuple> getInputQueue()
public String getComponentId()
getComponentId
in class LightComponent
public int getExecutors()
public org.apache.storm.topology.IRichBolt getClonedBoltInstance()
Copyright © 2023. All rights reserved.