Package | Description |
---|---|
org.apache.storm.streams |
Modifier and Type | Method and Description |
---|---|
<K,V> PairStream<K,V> |
Stream.flatMapToPair(PairFlatMapFunction<? super T,? extends K,? extends V> function)
Returns a stream consisting of the results of replacing each value of this stream with the key-value pairs produced by applying the provided mapping function to each value.
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.