开发者学堂课程【《实时计算 Flink 版产品入门与实操》:如何跑通第一个 SQL 作业】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/334/detail/3739
如何跑通第一个 SQL 作业
内容概括:
一、基本概念
二、语法说明
三、SQL 实例
一、基本概念
DQL 数据查询语言
DML 数据操控语言
DDL 数据定义语言
DCL 数据控制语言
SCripts SQL 文本,可写语句
Schema 表
函数
Artifacts 注册 UDF JAR
管理元数据
表:catalog .DB.Table
函数:UDF、UDTF
Deployment
作业描述
升级类型
升级策略
Flink 版本
CPU 和内存
期望状态
Running,cancelled、suspended
实际状态
Running,cancelled、suspended、FINISHED
作业实例
对应的 FLINK JOB
二、语法说明
注册函数
内置函数
自定义函数
CreateTable
会注册到系统 Catalog
适合多个 query 共享元数据
Create Temporary Table
会使用内存的 catalog
适合不需要共享元数据的场景
Create Temporary View
简化 SQL 语句
Statement Set
适合需要输出多个下游
三、实战 SQL
首先打开界面
创建原表
用户 ID、商品 ID、商品类目 ID、行为类型(点击、加购等)和时间。
查询
INSERT INTO
Buy-cnt-per-hour
SELECT
HOUR(TUMBLE-START(ts,INTERVAL1HOUR))
FROM
USER-behavior
WHERE
Behavior=buy
可以先点验证,再点运行
写 SQL 语句
设置作业名称
接着做这个练习
注册函数
上传 JAR 包
自动注册
手动注册