public class OnKeyedStream<T,K> extends Object
param: stream The wrapped data stream
Constructor and Description |
---|
OnKeyedStream(KeyedStream<T,K> stream) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
foldWith(R initialValue,
scala.Function2<R,T,R> fun,
TypeInformation<R> evidence$1)
Folds the stream over a zero element with a reducer
fun |
DataStream<T> |
reduceWith(scala.Function2<T,T,T> fun)
Applies a reducer
fun to the stream |
public OnKeyedStream(KeyedStream<T,K> stream)
public DataStream<T> reduceWith(scala.Function2<T,T,T> fun)
fun
to the stream
fun
- The reducing function to be applied on the keyed streampublic <R> DataStream<R> foldWith(R initialValue, scala.Function2<R,T,R> fun, TypeInformation<R> evidence$1)
fun
initialValue
- The zero elementfun
- The reducing function to be applied on the keyed streamevidence$1
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.