检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
DLI开启Checkpoint有两种方式: 在作业代码中配置Checkpoint相关参数,适用于Flink 1.15及历史Flink版本。 在DLI管理控制台的Jar作业配置界面开启Checkpoint,适用于Flink 1.15及更高的引擎版本。 Flink 1.15版本请勿重复在作业代码和Jar作业配置界面
列值支持所有数据类型,可以转换为DOUBLE类型后参与运算。 返回值说明 返回DOUBLE类型的值。 如果col值为NULL时,该列不参与计算。 示例代码 计算所有仓库的平均商品数(items)。命令示例如下: select avg(items) from warehouse; 返回结果如下:
str非STRING、BIGINT、DOUBLE、DECIMAL或DATETIME类型时,返回报错。 str值为NULL时,返回NULL。 示例代码 计算字符串abc的长度。命令示例如下。 返回3。 select length('abc'); 输入参数为NULL。命令示例如下。 返回NULL。
返回值的类型与col类型相同。返回规则如下: col值为NULL时,该行不参与计算。 col为BOOLEAN类型时,不允许参与运算。 示例代码 计算所有商品的最低库存(items)。命令示例如下: select min(items) from warehouse; 返回结果如下:
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回54。 select minute('2023-08-10 10:54:00'); 返回54。 select minute('10:54:00');
换返回DOUBLE类型;STRING、DATETIME之间的转换返回DATETIME类型。不允许其他的隐式转换。 NULL为最小值。 示例代码 返回2。 select ordinal(3, 1, 3, 2, 5, 2, 4, 9); 父主题: 其他函数
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回36。 select second('2023-08-16 10:54:36'); 返回36。 select second('10:54:36');
指定编码格式,支持GBK或UTF-8等标准编码格式,不输入默认为UTF-8。 返回值说明 返回STRING类型的值。 STRING类型UTF-8编码的字符串。 示例代码 返回 Example for URL_DECODE:// dsf(fasfs)。 select url_decode('Example+
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回2。 select weekday ('2023-08-16 10:54:36'); 返回NULL。 select weekday (null);
返回值的类型与col类型相同。返回规则如下: col值为NULL时,该行不参与计算。 col为BOOLEAN类型时,不允许参与运算。 示例代码 计算所有商品的最高库存(items)。命令示例如下: select max(items) from warehouse; 返回结果如下:
参数p非DOUBLE类型时,会隐式转换为DOUBLE类型后参与运算。 返回值说明 返回DOUBLE类型的值。 a、p为NULL,则返回NULL。 示例代码 返回16。 select pow(2, 4); 返回NULL。 select pow(2, null); 返回17.429460393524256。
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回3。 select quarter('2023-08-16 10:54:00'); 返回3。 select quarter('2023-08-16');
从左开始截取length位的字符串。 如果length为0,则返回空串。 如果没有输入参数或任一输入参数值为NULL,返回NULL。 示例代码 返回 hi???。 SELECT rpad('hi', 5, '??'); 返回 h。 SELECT rpad('hi', 1, '??');
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回33。 select weekofyear('2023-08-16 10:54:36'); 返回NULL。 select weekofyear('20230816');
作业的处理能力。 例如访问DWS大批量数据库数据时设置并发数,启动多任务的方式运行,避免作业运行超时。 具体并发设置可以参考对接DWS样例代码中的partitionColumn和numPartitions相关字段和案例描述。 调整Spark作业的Executor数量,分配更多的资源用于Spark作业的运行。
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 示例代码 返回1。 select day('2023-08-01'); 返回NULL。 select day('20230816'); 返回NULL。
表1 参数说明 参数 是否必选 说明 col 是 数据类型为数值的列。其他类型返回NULL。 返回值说明 返回DOUBLE类型的值。 示例代码 计算所有商品库存(items)的偏差。命令示例如下: select stddev_pop(items) from warehouse; 返回结果如下:
表1 参数说明 参数 是否必选 说明 col 是 数据类型为数值的列。其他类型返回NULL。 返回值说明 返回DOUBLE类型的值。 示例代码 计算所有商品库存(items)的样本偏差。命令示例如下: select stddev_samp(items) from warehouse;
表1 参数说明 参数 是否必选 说明 col 是 数据类型为数值的列。 其他类型返回NULL。 返回值说明 返回DOUBLE类型的值。 示例代码 计算所有商品库存(items)的样本方差。命令示例如下: select var_samp(items) from warehouse; 返回结果如下:
<scope>provided</scope> </dependency> 示例代码 本章节JAVA样例代码演示如何获取BasicCredentials,以及取临时委托的AK、SK、SecurityToken。 Flink UDF 获取作业委托凭证