说明
当前版本可用的函数列表,
举例
| 名称不区分大小写 | type | desc | |
| AesDecrypt | udf | aes对称解密, AES_DECRYPT(str, key) | |
| aes_decrypt | udf | aes对称解密, AES_DECRYPT(str, key) | |
| aesDecrypt | udf | aes对称解密, AES_DECRYPT(str, key) | |
| AesEncrypt | udf | aes对称加密 TODO, AES_ENCRYPT(str, key) | |
| aes_encrypt | udf | aes对称加密 TODO, AES_ENCRYPT(str, key) | |
| aesEncrypt | udf | aes对称加密 TODO, AES_ENCRYPT(str, key) | |
| abs | udf | 指定值强转浮点数并取绝对值 | |
| acos | udf | acos 反余弦 | |
| add | udf | 多个数相加 | |
| addDays | udf | 增加指定天 addDays(date, 1) | |
| add_days | udf | 增加指定天 addDays(date, 1) | |
| addHours | udf | 增加指定小时 addHours(date, 1) | |
| add_hours | udf | 增加指定小时 addHours(date, 1) | |
| addMinutes | udf | 增加指定分钟 addMinutes(date, 1) | |
| add_minutes | udf | 增加指定分钟 addMinutes(date, 1) | |
| addMonths | udf | 增加指定月 addMonths(date, 1) | |
| add_months | udf | 增加指定月 addMonths(date, 1) | |
| addSeconds | udf | 增加指定秒钟 addSeconds(date, 1) | |
| add_seconds | udf | 增加指定秒钟 addSeconds(date, 1) | |
| addWeeks | udf | 增加指定周 addWeeks(date, 1) | |
| add_weeks | udf | 增加指定周 addWeeks(date, 1) | |
| addYears | udf | 增加指定年 addYears(date, 1) | |
| add_years | udf | 增加指定年 addYears(date, 1) | |
| array | udf | 构造数组 | |
| arraySize | udf | 获取数组/集合的大小, null返回0, 其他返回1 | |
| array_size | udf | 获取数组/集合的大小, null返回0, 其他返回1 | |
| arrayLength | udf | 获取数组/集合的大小, null返回0, 其他返回1 | |
| array_length | udf | 获取数组/集合的大小, null返回0, 其他返回1 | |
| array_to_string | udf | 使用指定字符将数组连接为字符串 array_to_string(array_expression, delimiter) (pgsql) | |
| arrayToString | udf | 使用指定字符将数组连接为字符串 array_to_string(array_expression, delimiter) (pgsql) | |
| asin | udf | asin 反正弦 | |
| atan | udf | atan 反正切 | |
| base64 | udf | 返回base64 (根据RFC822规定，BASE64Encoder编码每76个字符，还需要加上一个回车换行) | |
| to_base64 | udf | 返回base64 (根据RFC822规定，BASE64Encoder编码每76个字符，还需要加上一个回车换行) | |
| toBase64 | udf | 返回base64 (根据RFC822规定，BASE64Encoder编码每76个字符，还需要加上一个回车换行) | |
| calc | udf | 四则运算 | |
| cast | udf | 强转参数为指定类型 | |
| tryCast | udf | 强转参数为指定类型 | |
| try_cast | udf | 强转参数为指定类型 | |
| coalesce | udf | 获取第一个非null值 | |
| compare | udf | 比较2个值的大小(两个值的类型可以不同) | |
| concat | udf | 字符串连接 (只要有一个值是 null 则返回 null) | |
| concatWs | udf | 字符串连接，只要有一个字符串不是NULL，就不会返回NULL, 第一个参数是分隔符 | |
| concat_ws | udf | 字符串连接，只要有一个字符串不是NULL，就不会返回NULL, 第一个参数是分隔符 | |
| conv | udf | 进制转换 conv('FF', 16, 10) | |
| convert | udf | 格式转换 | |
| cos | udf | cos 余弦 | |
| cot | udf | cot 余切 | |
| curdate | udf | 今天零点 | |
| dateAdd | udf | 增加指定时间 | |
| date_add | udf | 增加指定时间 | |
| addDate | udf | 增加指定时间 | |
| add_date | udf | 增加指定时间 | |
| dateFormat | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| date_format | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| fromUnixtime | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| from_unixtime | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| dateToString | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| date_to_string | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| dateToStr | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| date_to_str | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| formatDate | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| format_date | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| formatDateTime | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| format_date_time | udf | 时间格式化(兼容mysql/java风格的时间模板) | |
| dateSub | udf | 减去指定时间 | |
| date_sub | udf | 减去指定时间 | |
| subDate | udf | 减去指定时间 | |
| sub_date | udf | 减去指定时间 | |
| day | udf | 获得该时日是当月第几天, 1-31, null返回-1 | |
| dayOfMonth | udf | 获得该时日是当月第几天, 1-31, null返回-1 | |
| day_of_month | udf | 获得该时日是当月第几天, 1-31, null返回-1 | |
| toDayOfMonth | udf | 获得该时日是当月第几天, 1-31, null返回-1 | |
| to_day_of_month | udf | 获得该时日是当月第几天, 1-31, null返回-1 | |
| dayOfWeek | udf | 返回参数是星期几 参数不是日期=返回-1 1=周日;2=周一;7=周六 ODBC标准 | |
| day_of_week | udf | 返回参数是星期几 参数不是日期=返回-1 1=周日;2=周一;7=周六 ODBC标准 | |
| toDayOfWeek | udf | 返回参数是星期几 参数不是日期=返回-1 1=周日;2=周一;7=周六 ODBC标准 | |
| to_day_of_week | udf | 返回参数是星期几 参数不是日期=返回-1 1=周日;2=周一;7=周六 ODBC标准 | |
| dayOfYear | udf | 返回date 是当年第几天, 范围: 1-366 | |
| day_of_year | udf | 返回date 是当年第几天, 范围: 1-366 | |
| toDayOfYear | udf | 返回date 是当年第几天, 范围: 1-366 | |
| to_day_of_year | udf | 返回date 是当年第几天, 范围: 1-366 | |
| divide | udf | 多个数相除(除零返回零) | |
| divisionPercent | udf | 两个数相除后显示为百分比(默认格式0.00%) | |
| division_percent | udf | 两个数相除后显示为百分比(默认格式0.00%) | |
| dubboInvoke | udf | 测试指定 dubbo 服务: dubboInvoke(zk或dubbo地址, 类名.方法名(参数) [, 返回类型]) | |
| dubbo_invoke | udf | 测试指定 dubbo 服务: dubboInvoke(zk或dubbo地址, 类名.方法名(参数) [, 返回类型]) | |
| dubboList | udf | 查找指定 dubbo 服务: dubboList(zk或dubbo地址, 类名regex | |
| dubbo_list | udf | 查找指定 dubbo 服务: dubboList(zk或dubbo地址, 类名regex | |
| execSql | udf | (实验性功能)用于循环执行某些命令 | |
| exec_sql | udf | (实验性功能)用于循环执行某些命令 | |
| findInSet | udf | 逗号分隔参数二, 然后寻找参数一的位置, 找不到则返回 0 | |
| find_in_set | udf | 逗号分隔参数二, 然后寻找参数一的位置, 找不到则返回 0 | |
| firstDay | udf | 返回参数当月第一天的时间格式 | |
| first_day | udf | 返回参数当月第一天的时间格式 | |
| floor | udf | 向0取整 | |
| fromDays | udf | 根据公元元年至参数时间之间的天数返回日期(与to_days函数相反) | |
| from_days | udf | 根据公元元年至参数时间之间的天数返回日期(与to_days函数相反) | |
| from_base64 | udf | 解码base64, 返回 byte[] (忽略换行符) | |
| fromBase64 | udf | 解码base64, 返回 byte[] (忽略换行符) | |
| from_base64_to_str | udf | 解码base64, 返回 string (忽略换行符) | |
| fromBase64ToStr | udf | 解码base64, 返回 string (忽略换行符) | |
| greatest | udf | 返回最大参数 greatest(1,3,5,7,9,0) 返回 9 | |
| hex | udf | hex 对象转16进制 | |
| hour | udf | 返回小时, 范围: 0~23 | |
| toHour | udf | 返回小时, 范围: 0~23 | |
| to_hour | udf | 返回小时, 范围: 0~23 | |
| humpToLine | udf | 驼峰转下划线 | |
| hump_to_line | udf | 驼峰转下划线 | |
| if | udf | 根据参数1是否为true,返回参数2或者参数3 | |
| ifNull | udf | 根据参数1是否为null,返回参数1或者参数2 | |
| if_null | udf | 根据参数1是否为null,返回参数1或者参数2 | |
| nvl | udf | 根据参数1是否为null,返回参数1或者参数2 | |
| instr | udf | 字符串查找 | |
| ipAddrLow | udf | 获取指定网段的ip开头, 用于IP归属地等运算 ipAddrLow('10.9.8.7/24') 返回 '10.9.8.1' | |
| ip_addr_low | udf | 获取指定网段的ip开头, 用于IP归属地等运算 ipAddrLow('10.9.8.7/24') 返回 '10.9.8.1' | |
| isIpInSubnet | udf | 判断指定地址是否属于指定网段 isIpInSubnet('10.9.8.7', '10.9.8.7/24,10.10.10.7/24') 返回 true | |
| is_ip_in_subnet | udf | 判断指定地址是否属于指定网段 isIpInSubnet('10.9.8.7', '10.9.8.7/24,10.10.10.7/24') 返回 true | |
| isMobile | udf | 判断是不是合法手机号(130~190开头的11位整数) | |
| is_mobile | udf | 判断是不是合法手机号(130~190开头的11位整数) | |
| isPortOpen | udf | 检查某个服务器端口是否可达. isPortOpen('www.baidu.com', 80, '80端口可访问', '80端口不可访问'), isPortOpen('www.baidu.com', 80) 默认返回: true, false | |
| is_port_open | udf | 检查某个服务器端口是否可达. isPortOpen('www.baidu.com', 80, '80端口可访问', '80端口不可访问'), isPortOpen('www.baidu.com', 80) 默认返回: true, false | |
| javaBeanToSql | udf | java bean 对象 转 sql | |
| java_bean_to_sql | udf | java bean 对象 转 sql | |
| java_substring | udf | 字符串裁剪,(从0开始算) | |
| javaSubstring | udf | 字符串裁剪,(从0开始算) | |
| jsonValid | udf | 验证json合法性, 返回1那么JSON是有效的；返回0则表示JSON无效。 | |
| json_valid | udf | 验证json合法性, 返回1那么JSON是有效的；返回0则表示JSON无效。 | |
| json_contains | udf | 检查JSON文档是否包含指定的值或键 json_contains(data, 'x', '$.name') | |
| jsonContains | udf | 检查JSON文档是否包含指定的值或键 json_contains(data, 'x', '$.name') | |
| json_extract | udf | 从 json 中获取指定值 JSON_EXTRACT(data, '$.name') | |
| jsonExtract | udf | 从 json 中获取指定值 JSON_EXTRACT(data, '$.name') | |
| json_keys | udf | 获取 json keys | |
| jsonKeys | udf | 获取 json keys | |
| json_length | udf | 获取 json length | |
| jsonLength | udf | 获取 json length | |
| json_query | udf | 从 json 中获取指定值 json_query(data, '$.name') | |
| jsonQuery | udf | 从 json 中获取指定值 json_query(data, '$.name') | |
| json_value | udf | 从 json 中获取指定值 json_value(data, '$.name', 'INT') | |
| jsonValue | udf | 从 json 中获取指定值 json_value(data, '$.name', 'INT') | |
| lastDay | udf | 返回参数当月最后一天的时间格式 | |
| last_day | udf | 返回参数当月最后一天的时间格式 | |
| least | udf | 返回函数括号里的最小值 greatest(1,3,5,7,9,0) 返回 0 | |
| left | udf | 从左边截取字符 | |
| length | udf | 返回参数转字符串后的长度(每个中文算多个字节), 如果入参是数组或集合类, 则返回其大小 | |
| lineToHump | udf | 下划线转驼峰 | |
| line_to_hump | udf | 下划线转驼峰 | |
| locate | udf | 返回substr在字符串str的第一个出现的位置 | |
| lower | udf | 返回参数转字符串后的小写格式 | |
| toLowerCase | udf | 返回参数转字符串后的小写格式 | |
| to_lower_case | udf | 返回参数转字符串后的小写格式 | |
| lpad | udf | 从左边对字符串使用指定的字符进行填充(一中文算多个字节) | |
| masking | udf | 数据脱敏工具, 将数据的全部或部分替换为星号, 不保证返回值与输入值长度一致 | |
| maxDateValue | udf | 求所有参数中的最大时间 | |
| max_date_value | udf | 求所有参数中的最大时间 | |
| maxNumberValue | udf | 求所有参数中的最大数字 | |
| max_number_value | udf | 求所有参数中的最大数字 | |
| maxValue | udf | 求所有参数中的最大值 | |
| max_value | udf | 求所有参数中的最大值 | |
| md5 | udf | 返回参数32位MD5 | |
| md5_16 | udf | 返回参数16位MD5 | |
| md516 | udf | 返回参数16位MD5 | |
| minDateValue | udf | 求所有参数中的最小时间 | |
| min_date_value | udf | 求所有参数中的最小时间 | |
| minNumberValue | udf | 求所有参数中的最小数字 | |
| min_number_value | udf | 求所有参数中的最小数字 | |
| minValue | udf | 求所有参数中的最小值 | |
| min_value | udf | 求所有参数中的最小值 | |
| minute | udf | 返回分钟, 范围: 0~23 | |
| mod | udf | 取余 | |
| month | udf | 获得指定时间的月份, mysql风格, null返回-1, 一月返回1 | |
| toMonth | udf | 获得指定时间的月份, mysql风格, null返回-1, 一月返回1 | |
| to_month | udf | 获得指定时间的月份, mysql风格, null返回-1, 一月返回1 | |
| multiply | udf | 多个数相乘 | |
| now | udf | 当前时间 | |
| nullIf | udf | 如果两个指定的表达式相等，就返回NULL值, 否则返回第一个值 | |
| null_if | udf | 如果两个指定的表达式相等，就返回NULL值, 否则返回第一个值 | |
| ori_decode | udf | 私加解密函数 | |
| oriDecode | udf | 私加解密函数 | |
| ori_encode | udf | 私有解密函数 | |
| oriEncode | udf | 私有解密函数 | |
| parseSqlToTables | udf | 解析sql并从中获取表名(只能解析完整的sql) | |
| parse_sql_to_tables | udf | 解析sql并从中获取表名(只能解析完整的sql) | |
| parse_url | udf | 解析 url 并返回其指定部分, 支持 HOST,PATH,QUERY,REF,PROTOCOL,FILE,AUTHORITY,USERINFO | |
| parseUrl | udf | 解析 url 并返回其指定部分, 支持 HOST,PATH,QUERY,REF,PROTOCOL,FILE,AUTHORITY,USERINFO | |
| pi | udf | 圆周率(3.14159265358979323846) | |
| ping | udf | 检查某个服务器端口是否可达. ping('www.baidu.com', 'ping成功', 'ping失败', 1000), ping('www.baidu.com:8443') 默认: 成功返回 ping 毫秒数, 失败返回 null. 本方法与操作系统的 ping, tcping 逻辑类似但不完全相同 | |
| pow | udf | 求幂 | |
| province | udf | 整理中国省份名,返回省份简称,用于渲染echarts | |
| provinceCity | udf | 整理中国省份城市名,返回简称,用于渲染echarts等场景 | |
| province_city | udf | 整理中国省份城市名,返回简称,用于渲染echarts等场景 | |
| quarter | udf | 返回当前月是第几个季度 范围:1-4 | |
| toQuarter | udf | 返回当前月是第几个季度 范围:1-4 | |
| to_quarter | udf | 返回当前月是第几个季度 范围:1-4 | |
| rand | udf | 获取随机数, 0~1之间 | |
| replace | udf | 字符串替换(普通文本替换) | |
| replaceAll | udf | 字符串替换(正则替换) | |
| replace_all | udf | 字符串替换(正则替换) | |
| regexpReplace | udf | 字符串替换(正则替换) | |
| regexp_replace | udf | 字符串替换(正则替换) | |
| right | udf | 从右边截取字符 | |
| round | udf | 四舍五入, 向上(正无穷)取整 | |
| rpad | udf | 从右边对字符串使用指定的字符进行填充(一中文算多个字节) | |
| runtimeName | udf | 当前服务器信息(PID@机器名:内网IP:端口号), IP地址和端口号可能获取不到 | |
| runtime_name | udf | 当前服务器信息(PID@机器名:内网IP:端口号), IP地址和端口号可能获取不到 | |
| second | udf | 返回秒数, 范围: 0~59 | |
| serverProperty | udf | 获取环境变量 | |
| server_property | udf | 获取环境变量 | |
| serviceStartTime | udf | 当前服务器初始化时间 | |
| service_start_time | udf | 当前服务器初始化时间 | |
| sin | udf | sin 正弦 | |
| sleep | udf | 休眠若干毫秒(模拟慢查询, 最大支持休眠1分钟) | |
| snowFlakeId | udf | 返回一个雪花id | |
| snow_flake_id | udf | 返回一个雪花id | |
| split | udf | 字符串拆分为数组 split('a,b,c', ',') | |
| splitSqlToTables | udf | 利用from/join关键词从sql中搜索表名(可以解析不完整的sql) | |
| split_sql_to_tables | udf | 利用from/join关键词从sql中搜索表名(可以解析不完整的sql) | |
| splitSubstring | udf | 使用正则拆分,并获取第N个字符串, 默认返回空字符串 splitSubstring(target,delimiter,index) | |
| split_substring | udf | 使用正则拆分,并获取第N个字符串, 默认返回空字符串 splitSubstring(target,delimiter,index) | |
| sqrt | udf | sqrt 平方根 | |
| strToDate | udf | 字符串转时间(允许不指定时间格式) | |
| str_to_date | udf | 字符串转时间(允许不指定时间格式) | |
| substring | udf | 字符串裁剪(注意从1开始算) | |
| substr | udf | 字符串裁剪(注意从1开始算) | |
| substring_index | udf | 获取指定字符附近的子字符串 | |
| substringIndex | udf | 获取指定字符附近的子字符串 | |
| subtract | udf | 多个数相减 | |
| subtractDays | udf | 减少指定天 subtractDays(date, 1) | |
| subtract_days | udf | 减少指定天 subtractDays(date, 1) | |
| subtractHours | udf | 减少指定小时 subtractHours(date, 1) | |
| subtract_hours | udf | 减少指定小时 subtractHours(date, 1) | |
| subtractMinutes | udf | 减少指定分钟 subtractMinutes(date, 1) | |
| subtract_minutes | udf | 减少指定分钟 subtractMinutes(date, 1) | |
| subtractMonths | udf | 减少指定月 subtractMonths(date, 1) | |
| subtract_months | udf | 减少指定月 subtractMonths(date, 1) | |
| subtractSeconds | udf | 减少指定秒钟 subtractSeconds(date, 1) | |
| subtract_seconds | udf | 减少指定秒钟 subtractSeconds(date, 1) | |
| subtractWeeks | udf | 减少指定周 subtractWeeks(date, 1) | |
| subtract_weeks | udf | 减少指定周 subtractWeeks(date, 1) | |
| subtractYears | udf | 减少指定年 subtractYears(date, 1) | |
| subtract_years | udf | 减少指定年 subtractYears(date, 1) | |
| tan | udf | tan 正切 | |
| timestampDiff | udf | 求两个时间的差 | |
| timestamp_diff | udf | 求两个时间的差 | |
| dateDiff | udf | 求两个时间的差 | |
| date_diff | udf | 求两个时间的差 | |
| toDate | udf | 指定值强转时间 | |
| to_date | udf | 指定值强转时间 | |
| toDateTimeEndString | udf | 指定值强转日期 yyyy-MM-dd 23:59:59 格式 | |
| to_date_time_end_string | udf | 指定值强转日期 yyyy-MM-dd 23:59:59 格式 | |
| toDayEndString | udf | 指定值强转日期 yyyy-MM-dd 23:59:59 格式 | |
| to_day_end_string | udf | 指定值强转日期 yyyy-MM-dd 23:59:59 格式 | |
| toDateTimeStartString | udf | 指定值强转日期 yyyy-MM-dd 00:00:00 格式 | |
| to_date_time_start_string | udf | 指定值强转日期 yyyy-MM-dd 00:00:00 格式 | |
| toDayStartString | udf | 指定值强转日期 yyyy-MM-dd 00:00:00 格式 | |
| to_day_start_string | udf | 指定值强转日期 yyyy-MM-dd 00:00:00 格式 | |
| toDateTimeString | udf | 指定值强转日期 yyyy-MM-dd HH:mm:ss 格式 | |
| to_date_time_string | udf | 指定值强转日期 yyyy-MM-dd HH:mm:ss 格式 | |
| toDayTimeString | udf | 指定值强转日期 yyyy-MM-dd HH:mm:ss 格式 | |
| to_day_time_string | udf | 指定值强转日期 yyyy-MM-dd HH:mm:ss 格式 | |
| toDayString | udf | 指定值强转日期 yyyy-mm-dd 格式 | |
| to_day_string | udf | 指定值强转日期 yyyy-mm-dd 格式 | |
| toDays | udf | 返回公元元年至day之间的天数(与from_days函数相反) | |
| to_days | udf | 返回公元元年至day之间的天数(与from_days函数相反) | |
| toDouble | udf | 指定值强转浮点数 | |
| to_double | udf | 指定值强转浮点数 | |
| toFloat | udf | 指定值强转(低精度)浮点数 | |
| to_float | udf | 指定值强转(低精度)浮点数 | |
| toInt | udf | 指定值强转整数(正负20亿) | |
| to_int | udf | 指定值强转整数(正负20亿) | |
| toJavaBean | udf | 对象转 java bean | |
| to_java_bean | udf | 对象转 java bean | |
| toList | udf | 指定值强转数组 toList('1,2,3') 或 toList('1', '2', '3') | |
| to_list | udf | 指定值强转数组 toList('1,2,3') 或 toList('1', '2', '3') | |
| toLong | udf | 指定值强转整数(正负900亿亿) | |
| to_long | udf | 指定值强转整数(正负900亿亿) | |
| toPercent | udf | 将数字强转百分比 toPercent(1/3) => 33.33% | |
| to_percent | udf | 将数字强转百分比 toPercent(1/3) => 33.33% | |
| toSelectAll | udf | create table 转 select 各个字段 | |
| to_select_all | udf | create table 转 select 各个字段 | |
| toSelectDescAll | udf | create table 转 select 各个字段as中文 | |
| to_select_desc_all | udf | create table 转 select 各个字段as中文 | |
| toSet | udf | 指定值强转数组(并去重) | |
| to_set | udf | 指定值强转数组(并去重) | |
| toString | udf | 指定值强转文本 | |
| to_string | udf | 指定值强转文本 | |
| toYYYYMM | udf | 指定值强转时间 | |
| to_y_y_y_y_m_m | udf | 指定值强转时间 | |
| toYYYYMMDD | udf | 指定值强转时间 | |
| to_y_y_y_y_m_m_d_d | udf | 指定值强转时间 | |
| toYYYYMMDDHHMMSS | udf | 指定值强转时间 | |
| to_y_y_y_y_m_m_d_d_h_h_m_m_s_s | udf | 指定值强转时间 | |
| to_pinyin | udf | to_pinyin 中文转拼音(不含声调) | |
| toPinyin | udf | to_pinyin 中文转拼音(不含声调) | |
| to_pinyin_first_initial | udf | to_pinyin_first_initial 中文转拼音首字符 (返回第一个字的首字母) | |
| toPinyinFirstInitial | udf | to_pinyin_first_initial 中文转拼音首字符 (返回第一个字的首字母) | |
| to_pinyin_initials | udf | to_pinyin_initials 中文转拼音首字符 (每个字返回首字母) | |
| toPinyinInitials | udf | to_pinyin_initials 中文转拼音首字符 (每个字返回首字母) | |
| trim | udf | 删除首尾空格或指定字符(允许指定删那边的空格) | |
| unhex | udf | 16进制字符串转对象 | |
| updateCreateTable | udf | 建表语句升级 updateCreateTable('create table ...', 'create table ...') | |
| update_create_table | udf | 建表语句升级 updateCreateTable('create table ...', 'create table ...') | |
| upper | udf | 返回参数转字符串后的大写格式 | |
| toUpperCase | udf | 返回参数转字符串后的大写格式 | |
| to_upper_case | udf | 返回参数转字符串后的大写格式 | |
| uuid | udf | 返回一个uuid | |
| version | udf | 当前版本号 | |
| weekDay | udf | 回date的星期索引(0=星期一，1=星期二, ……6= 星期天) | |
| week_day | udf | 回date的星期索引(0=星期一，1=星期二, ……6= 星期天) | |
| year | udf | 返回年份 | |
| toYear | udf | 返回年份 | |
| to_year | udf | 返回年份 | |
| argMax | udaf | ||
| arg_max | udaf | ||
| argMin | udaf | ||
| arg_min | udaf | ||
| avg | udaf | ||
| avgAny | udaf | 求平均数,null与0当作0参与计算 | |
| avg_any | udaf | 求平均数,null与0当作0参与计算 | |
| avga | udaf | 求平均数,null与0当作0参与计算 | |
| avgPositive | udaf | 求平均数,null与非正数会被忽略 | |
| avg_positive | udaf | 求平均数,null与非正数会被忽略 | |
| concatList | udaf | 类似与sql的MySQL中concat函数,任何一个值为null则返回null | |
| concat_list | udaf | 类似与sql的MySQL中concat函数,任何一个值为null则返回null | |
| count | udaf | ||
| countAll | udaf | 求 count 值 (null 也算数) | |
| count_all | udaf | 求 count 值 (null 也算数) | |
| countDistinct | udaf | ||
| count_distinct | udaf | ||
| dateList | udaf | 按日期求折线图数组 | |
| date_list | udaf | 按日期求折线图数组 | |
| first | udaf | 返回第一个非null值 | |
| anyValue | udaf | 返回第一个非null值 | |
| any_value | udaf | 返回第一个非null值 | |
| firstAny | udaf | 返回第一个值, 可以返回 null 值 | |
| first_any | udaf | 返回第一个值, 可以返回 null 值 | |
| firsta | udaf | 返回第一个值, 可以返回 null 值 | |
| firstNz | udaf | 返回第一个非零非null值 | |
| first_nz | udaf | 返回第一个非零非null值 | |
| firstPositive | udaf | 返回第一个正数值 | |
| first_positive | udaf | 返回第一个正数值 | |
| groupConcat | udaf | ||
| group_concat | udaf | ||
| jobScopeTime | udaf | 计算任务时长: jobScopeTime(时间轴, 时间间隔, 值[，唯一标识]) | |
| job_scope_time | udaf | 计算任务时长: jobScopeTime(时间轴, 时间间隔, 值[，唯一标识]) | |
| last | udaf | 获取最后一个值 | |
| lastAny | udaf | 返回最后一个值, 可以返回null | |
| last_any | udaf | 返回最后一个值, 可以返回null | |
| lasta | udaf | 返回最后一个值, 可以返回null | |
| lastNz | udaf | 返回最后一个非零非null值 | |
| last_nz | udaf | 返回最后一个非零非null值 | |
| lastPositive | udaf | 返回最后一个正数值 | |
| last_positive | udaf | 返回最后一个正数值 | |
| list | udaf | 将所有数据合并为一个数组 | |
| group_list | udaf | 将所有数据合并为一个数组 | |
| groupList | udaf | 将所有数据合并为一个数组 | |
| array_agg | udaf | 将所有数据合并为一个数组 | |
| arrayAgg | udaf | 将所有数据合并为一个数组 | |
| listAll | udaf | 将所有子数组合并为一个大数组 | |
| list_all | udaf | 将所有子数组合并为一个大数组 | |
| listAllDistinct | udaf | 将所有子数组合并为一个去重大数组 | |
| list_all_distinct | udaf | 将所有子数组合并为一个去重大数组 | |
| listDistinct | udaf | 将所有子数组去重合并为一个大数组 | |
| list_distinct | udaf | 将所有子数组去重合并为一个大数组 | |
| longList | udaf | 按指定数字x轴求折线图数组 | |
| long_list | udaf | 按指定数字x轴求折线图数组 | |
| map | udaf | 将数据组织成map格式 | |
| mapList | udaf | 将数据整合为指定 key 的List |
