1.前言

DWS作为MPP架构的数仓产品，其性能优势主要在分布式计算上。默认情况下，DWS为了保证结果的正确性，自定义函数默认属性是不下推的，这会导致计算不下推，从而导致比较验证的性能问题。本文主要描述下函数在满足特征的前提下可以把函数属性定义为下推属性。

在展开介绍之前，我们先介绍一下DWS里面函数的几个属性

2. 易变属性

3. 下推属性

4.自定义函数简单判断逻辑

需要关注字段funcdef_diagnosis输出为非NULL的记录

--输出列funcdef_diagnosis的取值有四个
--1. 输出为空
   ** 没有诊断出异常信息
--2. 输出为：ERROR: table operations in the stable/immutable function body
   ** 说明stable/immutable函数中可能出现了表操作动作（update|truncate|delete|insert|merge|create |drop| alter）
--3.输出为：NOTICE: the tableless operation function is determined not shippable
   ** 说明函数定义中没有表表操作，但是函数定义为不可下推
   ** 如果函数中没有表查询动作，并且不存在结果随机的函数，建议把函数定义为可下推的
--4.输出为：NOTICE: maybe table operations in the shippable function
   ** 说明可下推函数（proshippable = true 或者 provolatile= 'i'）中可能存在查询表的动作
   ** 函数中如果有表查询动作，建议把函数定义为不下推

WITH funcdef AS( SELECT
        rolname AS proowner,
        proshippable,
        provolatile,
        lanname,
        prosrc,
        prosrc ~* '(update|truncate|delete|insert|merge)' AS contain_dml,
        prosrc ~* '(create | drop | alter)' AS contain_ddl,
        prosrc ilike '%select%from%' AS contain_select,
        (pg_get_functiondef(p.oid)).definition AS functiondef
    FROM pg_proc p
    INNER JOIN pg_language l ON l.oid = p.prolang
    INNER JOIN pg_roles r ON r.oid = p.proowner
    WHERE p.oid >= 16384 -- 只检测自定义函数
    AND lanname IN ('sql','plpgsql')--只检测SQL和plpgsql函数
)
SELECT 
    proowner,
    proshippable,
    provolatile,
    lanname,
    contain_dml,
    contain_ddl,
    contain_select,
    CASE WHEN (contain_dml OR contain_ddl) THEN
            CASE WHEN provolatile IN ('i', 's') 
                THEN 'ERROR: table operations in the stable/immutable function body'
            END
        WHEN contain_select = false THEN
            CASE WHEN provolatile <> 'i' AND proshippable = false
                THEN 'NOTICE: the tableless operation function is determined not shippable'
            END
        WHEN contain_select THEN 
            CASE WHEN proshippable = true OR provolatile= 'i'
                THEN 'NOTICE: maybe table operations in the shippable function'
            END
    END AS funcdef_diagnosis,
    functiondef
FROM funcdef
;

4. 总结

函数下推要首先满足以下

1. 函数的易变属性为IMMUTABLE和STABLE
2. 函数的下推属性设置为SHIPPALE

可以在函数定义的时候指定SHIPPALE属性，可以通过ALTER语句修改函数的下推属性