org.apache.storm.solr.spout

Class SolrJsonSpout

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichSpout

org.apache.storm.solr.spout.SolrJsonSpout

All Implemented Interfaces:

Serializable, ISpout, IComponent, IRichSpout

public class SolrJsonSpout
extends BaseRichSpout

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SolrJsonSpout.JsonSchema

Constructor Summary

Constructors

Constructor and Description
SolrJsonSpout()

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

Constructor Detail

SolrJsonSpout

public SolrJsonSpout()

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