public class LocalFileTweetSpout extends LocalTweetSpout
collector
Constructor and Description |
---|
LocalFileTweetSpout(String... files) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
nextInputStream() |
void |
open(Map conf,
backtype.storm.task.TopologyContext context,
backtype.storm.spout.SpoutOutputCollector collector) |
ack, activate, addWaitingFor, close, deactivate, declareOutputFields, fail, getComponentConfiguration, isFinished, nextTuple, nextTweet
public LocalFileTweetSpout(String... files)
public void open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)
open
in interface backtype.storm.spout.ISpout
open
in class LocalTweetSpout
protected InputStream nextInputStream() throws FileNotFoundException
nextInputStream
in class LocalTweetSpout
FileNotFoundException