Package org.apache.flink.storm.util

Interface Summary

Interface	Description
FiniteSpout	This interface represents a spout that emits a finite number of records.
OutputFormatter

Class Summary

Class	Description
AbstractBoltSink	Implements a sink that write the received data so some external output.
AbstractLineSpout	Base class for Spouts that read data line by line from an arbitrary source.
BoltFileSink	Implements a sink that write the received data to the given file (as a result of Object.toString() for each attribute).
BoltPrintSink	Implements a sink that prints the received data to stdout.
FileSpout	Implements a Spout that reads data from a given local file.
FiniteFileSpout	Implements a Spout that reads data from a given local file.
FiniteInMemorySpout	Implements a Spout that reads String[] data stored in memory.
InMemorySpout<T>	Implements a Spout that reads data stored in memory.
NullTerminatingSpout	NullTerminatingSpout in a finite spout (ie, implements FiniteSpout interface) that wraps an infinite spout, and returns true in NullTerminatingSpout.reachedEnd() when the wrapped spout does not emit a tuple in nextTuple() for the first time.
SimpleOutputFormatter
SplitStreamMapper<T>	Strips SplitStreamType<T> away, ie, extracts the wrapped record of type T.
SplitStreamType<T>	Used by org.apache.flink.storm.wrappers.AbstractStormCollector to wrap output tuples if multiple output streams are declared.
StormConfig	StormConfig is used to provide a user-defined Storm configuration (ie, a raw Map or Config object) for embedded Spouts and Bolts.
StormStreamSelector<T>	Used by FlinkTopology to split multiple declared output streams within Flink.
TupleOutputFormatter