public abstract class LocalTweetSpout extends Object implements backtype.storm.topology.IRichSpout
Modifier and Type | Field and Description |
---|---|
protected backtype.storm.spout.SpoutOutputCollector |
collector |
Constructor and Description |
---|
LocalTweetSpout() |
Modifier and Type | Method and Description |
---|---|
void |
ack(Object msgId) |
void |
activate() |
protected void |
addWaitingFor(Object messageId) |
void |
close() |
void |
deactivate() |
void |
declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer) |
void |
fail(Object msgId) |
Map<String,Object> |
getComponentConfiguration() |
static boolean |
isFinished() |
protected abstract InputStream |
nextInputStream() |
void |
nextTuple() |
protected StreamJSONStatusList.ReadableWritableJSON |
nextTweet() |
void |
open(Map conf,
backtype.storm.task.TopologyContext context,
backtype.storm.spout.SpoutOutputCollector collector) |
protected backtype.storm.spout.SpoutOutputCollector collector
public LocalTweetSpout()
public void open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)
open
in interface backtype.storm.spout.ISpout
public void close()
close
in interface backtype.storm.spout.ISpout
public void activate()
activate
in interface backtype.storm.spout.ISpout
public void deactivate()
deactivate
in interface backtype.storm.spout.ISpout
public Map<String,Object> getComponentConfiguration()
getComponentConfiguration
in interface backtype.storm.topology.IComponent
public void nextTuple()
nextTuple
in interface backtype.storm.spout.ISpout
public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
declareOutputFields
in interface backtype.storm.topology.IComponent
protected StreamJSONStatusList.ReadableWritableJSON nextTweet()
protected abstract InputStream nextInputStream() throws Exception
Exception
public static boolean isFinished()
protected void addWaitingFor(Object messageId)