Package | Description |
---|---|
org.apache.flink.storm.util | |
org.apache.flink.storm.wordcount.operators |
Class and 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.
|
FileSpout
Implements a Spout that reads data from a given local file.
|
FiniteSpout
This interface represents a spout that emits a finite number of records.
|
InMemorySpout
Implements a Spout that reads data stored in memory.
|
OutputFormatter
Interface that is used to convert Storm
Tuples to a string before writing them out to a file or to the
console. |
SplitStreamType
Used by org.apache.flink.storm.wrappers.AbstractStormCollector to wrap
output tuples if multiple output streams are declared.
|
Class and Description |
---|
AbstractLineSpout
Base class for Spouts that read data line by line from an arbitrary source.
|
FileSpout
Implements a Spout that reads data from a given local file.
|
FiniteInMemorySpout
Implements a Spout that reads String[] data stored in memory.
|
FiniteSpout
This interface represents a spout that emits a finite number of records.
|
InMemorySpout
Implements a Spout that reads data stored in memory.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.