org.openimaj.picslurper

Class DownloadBolt

java.lang.Object

org.openimaj.picslurper.DownloadBolt

All Implemented Interfaces:

backtype.storm.task.IBolt, backtype.storm.topology.IComponent, backtype.storm.topology.IRichBolt, Serializable

public class DownloadBolt
extends Object
implements backtype.storm.topology.IRichBolt

A download bolt instantiates StatusConsumer on Status recieved

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DownloadBolt(boolean stats, File globalStats, File outputLocation, List<OutputListener> outmodes) Information for the StatusConsumer instances

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup()
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	execute(backtype.storm.tuple.Tuple input)
Map<String,Object>	getComponentConfiguration()
void	prepare(Map stormConf, backtype.storm.task.TopologyContext context, backtype.storm.task.OutputCollector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

DownloadBolt

public DownloadBolt(boolean stats,
            File globalStats,
            File outputLocation,
            List<OutputListener> outmodes)

Information for the StatusConsumer instances

Parameters:

stats -

globalStats -

outputLocation -

outmodes -

Method Detail

prepare

public void prepare(Map stormConf,
           backtype.storm.task.TopologyContext context,
           backtype.storm.task.OutputCollector collector)

Specified by:

prepare in interface backtype.storm.task.IBolt

execute

public void execute(backtype.storm.tuple.Tuple input)

Specified by:

execute in interface backtype.storm.task.IBolt

cleanup

public void cleanup()

Specified by:

cleanup in interface backtype.storm.task.IBolt

declareOutputFields

public void declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)

Specified by:

declareOutputFields in interface backtype.storm.topology.IComponent

getComponentConfiguration

public Map<String,Object> getComponentConfiguration()

Specified by:

getComponentConfiguration in interface backtype.storm.topology.IComponent