| 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  FlatMapFunctionfunction 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 © 2019 The Apache Software Foundation. All rights reserved.