Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.process(CoProcessFunction<IN1,IN2,R> coProcessFunction)
Applies the given
CoProcessFunction on the connected input streams,
thereby creating a transformed output stream. |
<R> SingleOutputStreamOperator<R> |
ConnectedStreams.process(CoProcessFunction<IN1,IN2,R> coProcessFunction,
TypeInformation<R> outputType)
Applies the given
CoProcessFunction on the connected input streams,
thereby creating a transformed output stream. |
Modifier and Type | Class and Description |
---|---|
class |
RichCoProcessFunction<IN1,IN2,OUT>
Rich variant of the
CoProcessFunction . |
Constructor and Description |
---|
CoProcessOperator(CoProcessFunction<IN1,IN2,OUT> flatMapper) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
ConnectedStreams.process(CoProcessFunction<IN1,IN2,R> coProcessFunction,
TypeInformation<R> evidence$3)
Applies the given
CoProcessFunction on the connected input streams,
thereby creating a transformed output stream. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.