org.apache.flink.storm.split.operators

Class RandomSpout

java.lang.Object

backtype.storm.topology.base.BaseComponent

backtype.storm.topology.base.BaseRichSpout

org.apache.flink.storm.split.operators.RandomSpout

All Implemented Interfaces:

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

public class RandomSpout
extends backtype.storm.topology.base.BaseRichSpout

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	EVEN_STREAM
static String	ODD_STREAM

Constructor Summary

Constructors

Constructor and Description
RandomSpout(boolean split, long seed)

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(backtype.storm.topology.OutputFieldsDeclarer declarer)
void	nextTuple()
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.topology.IComponent

getComponentConfiguration

Field Detail

EVEN_STREAM

public static final String EVEN_STREAM

See Also:

Constant Field Values

ODD_STREAM

public static final String ODD_STREAM

See Also:

Constant Field Values

Constructor Detail

RandomSpout

public RandomSpout(boolean split,
                   long seed)

Method Detail

open

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

nextTuple

public void nextTuple()

declareOutputFields

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