org.openimaj.storm.spout

Class SimpleSpout

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichSpout

org.openimaj.storm.spout.SimpleSpout

All Implemented Interfaces:

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

public abstract class SimpleSpout
extends backtype.storm.topology.base.BaseRichSpout

This class just overrides some methods from IRichSpout so that you don't need to override them if you extend it.

Author:

pere

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected backtype.storm.spout.SpoutOutputCollector	collector
protected Map	conf
protected backtype.storm.task.TopologyContext	context

Constructor Summary

Constructors

Constructor and Description
SimpleSpout()

Method Summary

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

Methods inherited from class backtype.storm.topology.base.BaseRichSpout

ack, activate, close, deactivate, fail

Methods inherited from class backtype.storm.topology.base.BaseComponent

getComponentConfiguration

Methods inherited from class java.lang.Object

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

Methods inherited from interface backtype.storm.spout.ISpout

nextTuple

Methods inherited from interface backtype.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Field Detail

collector

protected backtype.storm.spout.SpoutOutputCollector collector

context

protected backtype.storm.task.TopologyContext context

conf

protected Map conf

Constructor Detail

SimpleSpout

public SimpleSpout()

Method Detail

open

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