public class OnConnectedStream<IN1,IN2> extends Object
Constructor and Description |
---|
OnConnectedStream(ConnectedStreams<IN1,IN2> stream) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
flatMapWith(scala.Function1<IN1,scala.collection.TraversableOnce<R>> flatMap1,
scala.Function1<IN2,scala.collection.TraversableOnce<R>> flatMap2,
TypeInformation<R> evidence$2)
Applies a CoFlatMap transformation on the connected streams.
|
<K1,K2> ConnectedStreams<IN1,IN2> |
keyingBy(scala.Function1<IN1,K1> key1,
scala.Function1<IN2,K2> key2,
TypeInformation<K1> evidence$3,
TypeInformation<K2> evidence$4)
Keys the two connected streams together.
|
<R> DataStream<R> |
mapWith(scala.Function1<IN1,R> map1,
scala.Function1<IN2,R> map2,
TypeInformation<R> evidence$1)
Applies a CoMap transformation on the connected streams.
|
public OnConnectedStream(ConnectedStreams<IN1,IN2> stream)
public <R> DataStream<R> mapWith(scala.Function1<IN1,R> map1, scala.Function1<IN2,R> map2, TypeInformation<R> evidence$1)
The transformation consists of two separate functions, where the first one is called for each element of the first connected stream, and the second one is called for each element of the second connected stream.
map1
- Function called per element of the first input.map2
- Function called per element of the second input.public <R> DataStream<R> flatMapWith(scala.Function1<IN1,scala.collection.TraversableOnce<R>> flatMap1, scala.Function1<IN2,scala.collection.TraversableOnce<R>> flatMap2, TypeInformation<R> evidence$2)
The transformation consists of two separate functions, where the first one is called for each element of the first connected stream, and the second one is called for each element of the second connected stream.
flatMap1
- Function called per element of the first input.flatMap2
- Function called per element of the second input.public <K1,K2> ConnectedStreams<IN1,IN2> keyingBy(scala.Function1<IN1,K1> key1, scala.Function1<IN2,K2> key2, TypeInformation<K1> evidence$3, TypeInformation<K2> evidence$4)
key1
- The first stream's key functionkey2
- The second stream's key functionCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.