org.apache.flink.storm.util

Class FiniteInMemorySpout

java.lang.Object

org.apache.flink.storm.util.AbstractLineSpout

org.apache.flink.storm.util.InMemorySpout<String>

org.apache.flink.storm.util.FiniteInMemorySpout

All Implemented Interfaces:

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

Direct Known Subclasses:

WordCountInMemorySpout

public class FiniteInMemorySpout
extends InMemorySpout<String>
implements FiniteSpout

Implements a Spout that reads String[] data stored in memory. The Spout stops automatically when it emitted all of the data.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.storm.util.InMemorySpout

counter, source

Fields inherited from class org.apache.flink.storm.util.AbstractLineSpout

ATTRIBUTE_LINE, collector

Constructor Summary

Constructors

Constructor and Description
FiniteInMemorySpout(String[] source)

Method Summary

Modifier and Type	Method and Description
boolean	reachedEnd() When returns true, the spout has reached the end of the stream.

Methods inherited from class org.apache.flink.storm.util.InMemorySpout

nextTuple

Methods inherited from class org.apache.flink.storm.util.AbstractLineSpout

ack, activate, close, deactivate, declareOutputFields, fail, getComponentConfiguration, open

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.spout.ISpout

ack, activate, close, deactivate, fail, nextTuple, open

Methods inherited from interface org.apache.storm.topology.IComponent

declareOutputFields, getComponentConfiguration

Constructor Detail

FiniteInMemorySpout

public FiniteInMemorySpout(String[] source)

Method Detail

reachedEnd

public boolean reachedEnd()

Description copied from interface: FiniteSpout

When returns true, the spout has reached the end of the stream.

Specified by:

reachedEnd in interface FiniteSpout

Returns:

true, if the spout's stream reached its end, false otherwise