私活-短平快项目
写在前面的话 开通本博客目的是与广大的程序人乃至IT人分享我个人接活的一些经验。尤其对于一线工作的辛苦程序人而言接点小活有时堪比半年的工资，比较可观。 给接活朋友的建议是，兼职就是兼职 ...
原文：技本功丨用短平快的方式告诉你：Flink-SQL的扩展实现
年 月 日，阿里云宣布开源 计算王牌 实时计算平台Blink回馈给ApacheFlink社区。官方称，计算延迟已经降到毫秒级，也就是你在浏览网页的时候，眨了一下眼睛，淘宝 天猫处理的信息已经刷新了 亿次。 作为一家对技术有追求 有渴望的公司，怎么少得了为Flink社区做些贡献呢 夫子说 首先，本文所述均基于flink . . 。 我们为什么扩展Flink SQL 由于Flink 本身SQL语法并 ...
2019-03-28 10:45 0 2245 推荐指数：
相关推荐
flink-sql解析canal-json实现实时同步
注意，下沉时下沉的表必须要有主键，否则会在更新数据时，旧数据和新数据会同时存在 ...
Flink基础（三十）：FLINK-SQL语法(六)DDL(三)ALTER 语句
0 简介 ALTER 语句用于修改一个已经在 Catalog 中注册的表、视图或函数定义。 Flink SQL 目前支持以下 ALTER 语句： ALTER TABLE ALTER DATABASE ALTER FUNCTION 1 执行 ALTER 语句 可以使 ...
Flink基础（三十六）：FLINK-SQL函数(1) 函数（一）概述
0 函数 Flink 允许用户在 Table API 和 SQL 中使用函数进行数据的转换。 1 函数类型 Flink 中的函数有两个划分标准。 一个划分标准是：系统（内置）函数和 Catalog 函数。系统函数没有名称空间，只能通过其名称来进行引用。 Catalog 函数属于 ...
Flink基础（二十七）：FLINK-SQL语法(三)DQL(三)查询语句（三）操作符（二）
5 OrderBy & Limit 操作符 描述 Order By批处理 流处理 注意： 流处理结果需主要根据 时间属性 ...
Flink基础（三十九）：FLINK-SQL函数(3) 函数（四）自定义函数（二）
1 标量函数 自定义标量函数可以把 0 到多个标量值映射成 1 个标量值，数据类型里列出的任何数据类型都可作为求值方法的参数和返回值类型。 想要实现自定义标量函数，你需要扩展 org.apache.flink.table.functions 里面的 ScalarFunction 并且实现一个 ...
Flink基础（四十一）：FLINK-SQL应用场景(2)Catalogs
0 简介 Catalog 提供了元数据信息，例如数据库、表、分区、视图以及数据库或其他外部系统中存储的函数和信息。 数据处理最关键的方面之一是管理元数据。 元数据可以是临时的，例如临时表、或者通过 ...
Flink基础（四十四）：FLINK-SQL函数(6) 内置函数（二）字符串函数（一）
字符串函数 STR_TO_MAP 语法 MAP STR_TO_MAP(VARCHAR text) MAP STR_TO_MAP(VARCHAR text, V ...