Uses of Interface
org.apache.storm.streams.operations.FlatMapFunction
Package
Description
-
Uses of FlatMapFunction in org.apache.storm.sql.runtime.streams.functions
-
Uses of FlatMapFunction in org.apache.storm.streams
Modifier and TypeMethodDescription<R> Stream<R>
Stream.flatMap
(FlatMapFunction<? super T, ? extends R> function) Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function to each value.<R> PairStream<K,
R> PairStream.flatMapValues
(FlatMapFunction<? super V, ? extends R> function) Return a new stream by applying aFlatMapFunction
function to the value of each key-value pairs in this stream. -
Uses of FlatMapFunction in org.apache.storm.streams.operations
-
Uses of FlatMapFunction in org.apache.storm.streams.processors
ModifierConstructorDescriptionFlatMapProcessor
(FlatMapFunction<T, R> function) FlatMapValuesProcessor
(FlatMapFunction<V, R> function)