检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配。 返回值说明 返回BIGINT类型的值。 如果没有匹配成功,返回0。 source、pattern值为NULL时,返回NULL。 示例代码 返回4。 select regexp_count('ab0a1a2b3c', '[0-9]'); 返回3。 select regexp_count('ab0a1a2b3c'
当length被省略时,返回到str结尾的子串。 str、start_position或length值为NULL时,返回NULL。 示例代码 返回 k SQL。 SELECT substr('Spark SQL', 5); 返回 SQL。 SELECT substr('Spark
date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 format值为NULL时,返回NULL。 示例代码 返回2023-08-01。 select trunc('2023-08-16', 'MM'); 返回2023-08-01。 select
测试)。如果能连通,则表示跨源已经绑定成功;否则表示未成功。 创建flink opensource sql作业,选择flink1.15版本,并提交运行,其代码如下: create table kafkaSource( id bigint, name string, description
colname可以为*,即count(*),返回所有行数。 返回值说明 返回BIGINT类型。 colname值为NULL时,该行不参与计算。 示例代码 计算所有仓库表中的记录数。命令示例如下: select count(*) from warehouse; 返回结果如下: _c0
日期值的入参格式时,返回NULL。 timestamp值为NULL时,返回NULL。 timezone值为NULL时,返回NULL。 示例代码 返回1692028800000。 select to_utc_timestamp('2023-08-14 17:00:00','PST');
get(“filename”)的方式获取。 SparkFiles.get()方法需要spark初始化以后才能调用。 图1 添加其他依赖文件 代码段如下所示 package main.java import org.apache.spark.SparkFiles import org
日期值的入参格式时,返回NULL; timestamp值为NULL时,返回NULL。 timezone值为NULL时,返回NULL。 示例代码 返回1691978400000(代表2023-08-14 10:00:00)。 select from_utc_timestamp('2023-08-14
UdfScalarFunction'; UDF UDF函数需继承ScalarFunction函数,并实现eval方法。open函数及close函数可选。 编写代码示例 import org.apache.flink.table.functions.FunctionContext; import org
日期值的入参格式时,返回NULL。 startdate值为NULL时,返回报错。 num_months值为NULL时,返回NULL。 示例代码 返回2023-05-26。 select add_months('2023-02-26',3); 返回2023-05-14。 select
回NULL。 转换过程以64位精度工作,溢出时返回NULL。 num如果输入的是小数,会转为整数值后进行进制转换,小数部分会被舍弃。 示例代码 -返回8。 select conv('1000', 2, 10); 返回B。 select conv('1011', 2, 16); 返回703710。
date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 format值为NULL时,返回NULL。 示例代码 返回2023-08-14。 select date_format('2023-08-14','yyyy-MM-dd'); 返回2023-08。
参数说明 目录监控 默认情况下,文件系统连接器是有界的,也就是只会扫描配置路径一遍后就会停止。 如果需要,可以通过设置 source.monitor-interval 属性来开启目录监控,以便在新文件出现时继续扫描。 键 默认值 类型 描述 source.monitor-interval
返回STRING类型的值。 返回最大的一级分区的值。 如果只是用alter table的方式新加了一个分区,但是此分区中并无任何数据,则此分区不会做为返回值。 示例代码 例如 table1 是分区表,该表对应的分区为20120801和20120802,且都有数据。则以下语句中max_pt返回值为‘20120802’。DLI
如果str2为空串,则总能匹配成功,例如select instr('abc','');会返回1。 str1或str2值为NULL时,返回NULL。 示例代码 计算字符b在字符串abc中的位置。命令示例如下。 返回2。 select instr('abc', 'b'); 任一输入参数为NULL。命令示例如下。
mismatch。 date为DATE或STRING类型,但不符合日期值的入参格式时,返回NULL。 format值为NULL时,返回NULL。 示例代码 返回静态数据示例2023-08*16。 select to_char('2023-08-16 10:54:36', '静态数据示例yyyy-mm*dd');
单位为秒。默认值为3600秒。 flink.dli.job.agency.name 是 - String 自定义委托名称。 样例代码 本章节JAVA样例代码演示将DataGen数据处理后写入到OBS,具体参数配置请根据实际环境修改。 创建DLI访问DEW的委托并完成委托授权。详细步骤请参考自定义DLI委托权限。
代表需要四舍五入到的位数。 参数d非INT类型时,会隐式转换为INT类型后参与运算。 返回值说明 返回DOUBLE类型。 a或d值为NULL时,返回NULL。 示例代码 返回123.4。 select bround(123.45,1); 返回123.6。 select bround(123.55,1); 返回NULL。
从左开始截取length位的字符串。 如果length为0,则返回空串。 如果没有输入参数或任一输入参数值为NULL,返回NULL。 示例代码 用字符串ZZ将字符串abcdefgh向左补足到10位。命令示例如下。 返回ZZabcdefgh。 select lpad('abcdefgh'
类型,但不符合日期值的入参格式时,返回NULL。 date值为NULL时,返回NULL。 format值为NULL时,返回NULL。 示例代码 返回2023-08-12。减2天。 select date_sub('2023-08-14 17:00:00', 2); 返回2023-08-15。增1天。