org.apache.flink.storm.util

Interface FiniteSpout

All Superinterfaces:

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

All Known Implementing Classes:

FiniteFileSpout, FiniteInMemorySpout, NullTerminatingSpout, WordCountInMemorySpout

public interface FiniteSpout
extends org.apache.storm.topology.IRichSpout

This interface represents a spout that emits a finite number of records. Common spouts emit infinite streams by default. To change this behavior and take advantage of Flink's finite-source capabilities, the spout should implement this interface.

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 interface org.apache.storm.spout.ISpout

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

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

declareOutputFields, getComponentConfiguration

Method Detail

reachedEnd

boolean reachedEnd()

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

Returns:

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