检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
proctime ASC) as row_num FROM Orders) WHERE row_num = 1; 父主题: 数据操作语句DML
ORDER BY 字句 示例 SELECT * FROM Orders ORDER BY orderTime LIMIT 3; 父主题: 数据操作语句DML
proctime ASC) as row_num FROM Orders) WHERE row_num = 1; 父主题: 数据操作语句DML
分组函数 表1 分组函数表 分组窗口函数 说明 TUMBLE(time_attr, interval) 定义一个滚动窗口。滚动窗口把行分配到有固定持续时间( interval )的不重叠的连续窗口。比如,5 分钟的滚动窗口以 5 分钟为间隔对行进行分组。滚动窗口可以定义在事件时间(
DLI提供了修改程序包组或程序包的所有者的功能。 登录DLI管理控制台,选择“数据管理 > 程序包管理”。 在“程序包管理”页面,单击程序包“操作 ”列中的“更多 > 修改所有者”。 如果该程序包进行过分组设置,选择“组”或者“程序包”进行修改。 图1 修改程序包所有者 如果该程序包
含了多少行数据。范围通过 BETWEEN 子句定义上下边界,其内的所有行都会聚合。Flink 只支持 CURRENT ROW 作为上边界。有两种方法可以定义范围:ROWS 间隔 和 RANGE 间隔: RANGE 间隔 RANGE 间隔是定义在排序列值上的,在 Flink 里,排序列总是一个时间属性。下面的
student GROUP BY name HAVING max(score) >95; 按列GROUP BY 功能描述 按列进行分组操作。 语法格式 1 2 3 4 SELECT [ ALL | DISTINCT ] { * | projectItem [, projectItem
proctime ASC) as row_num FROM Orders) WHERE row_num = 1; 父主题: 数据操作语句DML
proctime ASC) as row_num FROM Orders) WHERE row_num = 1; 父主题: 数据操作语句DML
sales DESC) as row_num FROM ShopSales) WHERE row_num <= 5; 父主题: 数据操作语句DML
sales DESC) as row_num FROM ShopSales) WHERE row_num <= 5; 父主题: 数据操作语句DML
sales DESC) as row_num FROM ShopSales) WHERE row_num <= 5; 父主题: 数据操作语句DML
创建作业后,您可以在DLI管理控制台查看Flink作业的基本信息、作业详情、任务列表、执行计划等信息。 本节操作介绍怎样查看Flink作业相关信息。 表1 查看Flink作业相关信息 类型 说明 操作指导 Flink作业基本信息 包括Flink作业的ID、作业类型、作业执行状态等信息。 查看Flink作业基本信息
ORDER BY 字句 示例 SELECT * FROM Orders ORDER BY orderTime LIMIT 3; 父主题: 数据操作语句DML
sales DESC) as row_num FROM ShopSales) WHERE row_num <= 5; 父主题: 数据操作语句DML
最终的结果。另外,窗口关联会清除不需要的中间状态。通常,窗口关联和 窗口表值函数 一起使用。而且,窗口关联可以在其他基于 窗口表值函数 的操作后使用,例如 窗口聚合,窗口 Top-N 和 窗口关联。目前,窗口关联需要在 join on 条件中包含两个输入表的 window_start
ORDER BY 字句 示例 SELECT * FROM Orders ORDER BY orderTime LIMIT 3; 父主题: 数据操作语句DML
10语法概览 Flink SQL语法概览 运维与监控 查看审计日志 查看监控指标 06 开发 您可以使用客户端或第三方BI工具对接DLI,以及通过DLI跨源连接进行数据分析。 客户端工具操作指导 使用Spark-submit提交作业 使用UDF操作指导 第三方BI工具对接DLI 永洪BI对接DLI
多级窗口聚合 window_start 和 window_end 列是普通的时间戳字段,并不是时间属性。因此它们不能在后续的操作中当做时间属性进行基于时间的操作。 为了传递时间属性,需要在 GROUP BY 子句中添加 window_time 列。window_time 是窗口表值函数(Windowing
解决方案 登录DLI管理控制台,选择“队列管理”,在队列管理界面查看是否有“SQL队列”类型的队列。 是,执行3。 否,执行2购买“SQL队列”类型的队列。 选择“资源管理 > 弹性资源池”,选择已购买的弹性资源池,单击操作列的“添加队列”,其中队列类型选择“SQL队列”,选择其他参数后提交创建。