Flink基础（二十七）：FLINK-SQL语法(三)DQL(三)查询语句（三）操作符（二）
5 OrderBy & Limit 操作符 描述 Order By批处理 流处理 注意： 流处理结果需主要根据 时间属性 按照升序进行排序。支持使用其他排序属性。 Limit批处理 ...
原文：Flink基础（二十六）：FLINK-SQL语法(二)DQL(二)查询语句（二）操作符（一）
Scan Projection 与 Filter 操作符 描述 Scan Select As批处理流处理 Where Filter批处理流处理 用户定义标量函数 Scalar UDF 批处理流处理 自定义函数必须事先注册到 TableEnvironment 中。 可阅读自定义函数文档以获得如何指定和注册自定义函数的详细信息。 聚合 操作符 描述 GroupBy 聚合批处理流处理结果更新 注意：G ...
2020-11-28 16:42 0 1014 推荐指数：
相关推荐
Flink基础（二十五）：FLINK-SQL语法 (一)DQL(一)查询语句（一）基本查询
来源：https://ci.apache.org/projects/flink/flink-docs-release-1.11/zh/dev/table/sql/queries.html 0 简介 SELECT 语句和 VALUES 语句需要使用 TableEnvironment ...
Flink基础（二十九）：FLINK-SQL语法(五)DDL(二)DROP 语句
0 简介 DROP 语句用于从当前或指定的 Catalog 中删除一个已经注册的表、视图或函数。 Flink SQL 目前支持以下 DROP 语句： DROP TABLE DROP DATABASE DROP VIEW DROP FUNCTION 1 执行 DROP ...
Flink基础（二十八）：FLINK-SQL语法(四)DDL(一)CREATE 语句
0 简介 CREATE 语句用于向当前或指定的 Catalog 中注册表、视图或函数。注册后的表、视图和函数可以在 SQL 查询中使用。 目前 Flink SQL 支持下列 CREATE 语句： CREATE TABLE CREATE DATABASE CREATE VIEW ...
Flink基础（三十）：FLINK-SQL语法(六)DDL(三)ALTER 语句
0 简介 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 执行 ALTER 语句 可以使 ...
Flink基础（120）：FLINK-SQL语法 (14) DQL(6) OPERATIONS(3) 窗口 (1) Windowing table-valued functions (Windowing TVFs)
Windowing table-valued functions (Windowing TVFs) Streaming 0 简介 Windows are at the heart of pro ...
Flink基础（三十六）：FLINK-SQL函数(1) 函数（一）概述
0 函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 1 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是：系统（内置）函数和 Catalog 函数。系统函数没有名称空间，只能通过其名称来进行引用。 Catalog 函数属于 ...
Flink基础（三十四）：FLINK-SQL语法(十)DDL(六)USE 语句
USE 语句用来设置当前的 catalog 或者 database。 1 运行一个 USE 语句 可以使用 TableEnvironment 中的 executeSql() 方法执行 USE 语句，也可以在 SQL CLI 中执行 USE 语句。 若 USE 操作执行成功，executeSql ...