org.apache.storm.pmml

Class RawInputFromCSVSpout

java.lang.Object

org.apache.storm.topology.base.BaseComponent

org.apache.storm.topology.base.BaseRichSpout

org.apache.storm.pmml.RawInputFromCSVSpout

All Implemented Interfaces:

Serializable, org.apache.storm.spout.ISpout, org.apache.storm.topology.IComponent, org.apache.storm.topology.IRichSpout

public class RawInputFromCSVSpout
extends org.apache.storm.topology.base.BaseRichSpout

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RawInputFromCSVSpout(File rawInputCsv, List<String> outputFields)

Method Summary

Modifier and Type	Method and Description
void	activate()
void	close()
void	deactivate()
void	declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)
static RawInputFromCSVSpout	newInstance(File csv)
void	nextTuple()
void	open(Map<String,Object> conf, org.apache.storm.task.TopologyContext context, org.apache.storm.spout.SpoutOutputCollector collector)

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

ack, 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

RawInputFromCSVSpout

public RawInputFromCSVSpout(File rawInputCsv,
                            List<String> outputFields)
                     throws FileNotFoundException

Throws:

FileNotFoundException

Method Detail

newInstance

public static RawInputFromCSVSpout newInstance(File csv)
                                        throws IOException

Throws:

IOException

open

public void open(Map<String,Object> conf,
                 org.apache.storm.task.TopologyContext context,
                 org.apache.storm.spout.SpoutOutputCollector collector)

nextTuple

public void nextTuple()

declareOutputFields

public void declareOutputFields(org.apache.storm.topology.OutputFieldsDeclarer declarer)

activate

public void activate()

Specified by:

activate in interface org.apache.storm.spout.ISpout

Overrides:

activate in class org.apache.storm.topology.base.BaseRichSpout

deactivate

public void deactivate()

Specified by:

deactivate in interface org.apache.storm.spout.ISpout

Overrides:

deactivate in class org.apache.storm.topology.base.BaseRichSpout

close

public void close()

Specified by:

close in interface org.apache.storm.spout.ISpout

Overrides:

close in class org.apache.storm.topology.base.BaseRichSpout