Package | Description |
---|---|
org.apache.storm.sql.runtime.streams.functions | |
org.apache.storm.streams | |
org.apache.storm.streams.operations | |
org.apache.storm.streams.processors |
Modifier and Type | Class and Description |
---|---|
class |
EvaluationCalc |
Modifier and Type | Method and Description |
---|---|
<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 a
FlatMapFunction function to the value of each key-value pairs in this stream. |
Modifier and Type | Interface and Description |
---|---|
interface |
PairFlatMapFunction<T,K,V>
|
Constructor and Description |
---|
FlatMapProcessor(FlatMapFunction<T,R> function) |
FlatMapValuesProcessor(FlatMapFunction<V,R> function) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.