Uses of Interface
org.apache.flink.streaming.api.functions.co.CoMapFunction
-
Packages that use CoMapFunction Package Description org.apache.flink.streaming.api.datastream org.apache.flink.streaming.api.functions.co org.apache.flink.streaming.api.operators.co -
-
Uses of CoMapFunction in org.apache.flink.streaming.api.datastream
Methods in org.apache.flink.streaming.api.datastream with parameters of type CoMapFunction Modifier and Type Method Description <R> SingleOutputStreamOperator<R>
ConnectedStreams. map(CoMapFunction<IN1,IN2,R> coMapper)
Applies a CoMap transformation on aConnectedStreams
and maps the output to a common type.<R> SingleOutputStreamOperator<R>
ConnectedStreams. map(CoMapFunction<IN1,IN2,R> coMapper, TypeInformation<R> outputType)
Applies a CoMap transformation on aConnectedStreams
and maps the output to a common type. -
Uses of CoMapFunction in org.apache.flink.streaming.api.functions.co
Classes in org.apache.flink.streaming.api.functions.co that implement CoMapFunction Modifier and Type Class Description class
RichCoMapFunction<IN1,IN2,OUT>
A RichCoMapFunction represents a Map transformation with two different input types. -
Uses of CoMapFunction in org.apache.flink.streaming.api.operators.co
Constructors in org.apache.flink.streaming.api.operators.co with parameters of type CoMapFunction Constructor Description CoStreamMap(CoMapFunction<IN1,IN2,OUT> mapper)
-