org.openimaj.picslurper

Class LocalFileTweetSpout

java.lang.Object

org.openimaj.picslurper.LocalTweetSpout

org.openimaj.picslurper.LocalFileTweetSpout

All Implemented Interfaces:

backtype.storm.spout.ISpout, backtype.storm.topology.IComponent, backtype.storm.topology.IRichSpout, Serializable

public class LocalFileTweetSpout
extends LocalTweetSpout

See Also:

Serialized Form

Field Summary

Fields inherited from class org.openimaj.picslurper.LocalTweetSpout

collector

Constructor Summary

Constructors

Constructor and Description
LocalFileTweetSpout(String... files)

Method Summary

Modifier and Type	Method and Description
protected InputStream	nextInputStream()
void	open(Map conf, backtype.storm.task.TopologyContext context, backtype.storm.spout.SpoutOutputCollector collector)

Methods inherited from class org.openimaj.picslurper.LocalTweetSpout

ack, activate, addWaitingFor, close, deactivate, declareOutputFields, fail, getComponentConfiguration, isFinished, nextTuple, nextTweet

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalFileTweetSpout

public LocalFileTweetSpout(String... files)

Method Detail

open

public void open(Map conf,
                 backtype.storm.task.TopologyContext context,
                 backtype.storm.spout.SpoutOutputCollector collector)

Specified by:

open in interface backtype.storm.spout.ISpout

Overrides:

open in class LocalTweetSpout

nextInputStream

protected InputStream nextInputStream()
                               throws FileNotFoundException

Specified by:

nextInputStream in class LocalTweetSpout

Throws:

FileNotFoundException