Constructor and Description |
---|
OnJoinedStream(JoinedStreams.Where.EqualTo.WithWindow<W> stream) |
Modifier and Type | Method and Description |
---|---|
<O> DataStream<O> |
projecting(scala.Function2<L,R,O> fun,
TypeInformation<O> evidence$1)
Completes the join operation with the user function that is executed
for windowed groups.
|
public OnJoinedStream(JoinedStreams.Where.EqualTo.WithWindow<W> stream)
public <O> DataStream<O> projecting(scala.Function2<L,R,O> fun, TypeInformation<O> evidence$1)
fun
- The function that defines the projection of the joinevidence$1
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.