org.apache.storm.solr.spout

Class SolrFieldsSpout

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichSpout

org.apache.storm.solr.spout.SolrFieldsSpout

All Implemented Interfaces:

Serializable, ISpout, IComponent, IRichSpout

public class SolrFieldsSpout
extends BaseRichSpout

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static List<Values>	listValues

Constructor Summary

Constructors

Constructor and Description
SolrFieldsSpout()

Method Summary

Modifier and Type	Method and Description
void	close()
void	declareOutputFields(OutputFieldsDeclarer declarer)
Fields	getOutputFields()
void	nextTuple()
void	open(Map conf, TopologyContext context, SpoutOutputCollector collector)

Methods inherited from class org.apache.storm.topology.base.BaseRichSpout

ack, activate, deactivate, fail

Methods inherited from class org.apache.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 org.apache.storm.topology.IComponent

getComponentConfiguration

Field Detail

listValues

public static final List<Values> listValues

Constructor Detail

SolrFieldsSpout

public SolrFieldsSpout()

Method Detail

open

public void open(Map conf,
                 TopologyContext context,
                 SpoutOutputCollector collector)

nextTuple

public void nextTuple()

declareOutputFields

public void declareOutputFields(OutputFieldsDeclarer declarer)

getOutputFields

public Fields getOutputFields()

close

public void close()

Specified by:

close in interface ISpout

Overrides:

close in class BaseRichSpout