pyflink.datastream.data_stream.ConnectedStreams.process

ConnectedStreams.process(func: Union[pyflink.datastream.functions.CoProcessFunction, pyflink.datastream.functions.KeyedCoProcessFunction], output_type: Optional[pyflink.common.typeinfo.TypeInformation] = None) → pyflink.datastream.data_stream.DataStream