public class LightSpout extends LightComponent implements LightAcker
componentId, streamDeclaration, subscribersPerStreamId, topologyContext
Constructor and Description |
---|
LightSpout(LightTopology topology,
String spoutComponentId,
org.thales.punch.libraries.storm.api.ISpout spout,
org.apache.storm.task.TopologyContext topologyContext) |
Modifier and Type | Method and Description |
---|---|
void |
ack(Object o)
Ack a (spout) tuple.
|
void |
emit(String streamId,
List<Object> values,
Object messageId)
Emit a spout tuple.
|
void |
fail(Object o)
Fail a (spout) tuple.
|
org.apache.storm.spout.ISpoutOutputCollector |
getLightSpoutOutputCollector() |
org.thales.punch.libraries.storm.api.ISpout |
getSpout() |
void |
increaseSleepTime(long l) |
boolean |
mustCallNextTuple() |
void |
nextTuple() |
void |
tick()
When a spout returned no tuple, or if the max pending limit has been reached,
the inactiveSpoutSleepInterval increases to avoid calling the spout.
|
addSubscriber, declareStream, getComponentId, getTopologyContext, publishStream
public LightSpout(LightTopology topology, String spoutComponentId, org.thales.punch.libraries.storm.api.ISpout spout, org.apache.storm.task.TopologyContext topologyContext)
public void ack(Object o)
LightAcker
ack
in interface LightAcker
o
- the associated objectpublic void emit(String streamId, List<Object> values, Object messageId)
streamId
- streamIdvalues
- valuesmessageId
- the associated spout messageId, an opaque object to be returned at ack or failure timepublic void fail(Object o)
LightAcker
fail
in interface LightAcker
o
- the associated objectpublic org.apache.storm.spout.ISpoutOutputCollector getLightSpoutOutputCollector()
public org.thales.punch.libraries.storm.api.ISpout getSpout()
public void increaseSleepTime(long l)
public boolean mustCallNextTuple()
public void nextTuple()
public void tick()
Copyright © 2023. All rights reserved.