public class OnDataStream<T> extends Object
Constructor and Description |
---|
OnDataStream(DataStream<T> stream) |
Modifier and Type | Method and Description |
---|---|
DataStream<T> |
filterWith(scala.Function1<T,Object> fun)
Applies a predicate
fun to each item of the stream, keeping only those for which
the predicate holds |
<R> DataStream<R> |
flatMapWith(scala.Function1<T,scala.collection.TraversableOnce<R>> fun,
TypeInformation<R> evidence$2)
Applies a function
fun to each item of the stream, producing a collection of items
that will be flattened in the resulting stream |
<K> KeyedStream<T,K> |
keyingBy(scala.Function1<T,K> fun,
TypeInformation<K> evidence$3)
Keys the items according to a keying function
fun |
<R> DataStream<R> |
mapWith(scala.Function1<T,R> fun,
TypeInformation<R> evidence$1)
Applies a function
fun to each item of the stream |
public OnDataStream(DataStream<T> stream)
public <R> DataStream<R> mapWith(scala.Function1<T,R> fun, TypeInformation<R> evidence$1)
fun
to each item of the stream
fun
- The function to be applied to each itempublic <R> DataStream<R> flatMapWith(scala.Function1<T,scala.collection.TraversableOnce<R>> fun, TypeInformation<R> evidence$2)
fun
to each item of the stream, producing a collection of items
that will be flattened in the resulting stream
fun
- The function to be applied to each itempublic DataStream<T> filterWith(scala.Function1<T,Object> fun)
fun
to each item of the stream, keeping only those for which
the predicate holds
fun
- The predicate to be tested on each itempublic <K> KeyedStream<T,K> keyingBy(scala.Function1<T,K> fun, TypeInformation<K> evidence$3)
fun
fun
- The keying functionCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.