作者 Rae 发布的文章

在flink table sql中我们还有一些场景，例如我们要在flink中对接hive执行相关的sql信息，此时就需要把hive的模块给引入进来，就需要使用到load函数，整个load函数的基础语法如下：LOAD ...

在flink table sql开发中还有一个我们常用的函数就是show，这里的show主要是为了查看某些信息，例如查看某个多数据源目录，某张表等等。这个show函数在传统的mysql中使用比较少，但是在大数据的场景...

在flink的table sql中analyze函数主要是用来做分析统计的，主要是统计表的信息，目前整个analyze函数主要应用于batch模式不能用于流模式，同时只能应用于表，不能应用于视图等。整个analyze...

在flink中我们还会涉及到经常插入数据的操作，在flink中我们使用insert的场景有如下2种情况：1、使用select把数据插入到对应的表中。 2、直接insert数据到对应的表中。前置：对应使用insert函...

在flink table sql中还有涉及到的alter函数，这里的alter主要是涉及到对原有的对象进行修改，目前在flink中支持的alter对象有：#修改表 alter table #修改视图 alter vi...

本文的话，我们介绍下对应的drop函数，这里的drop函数很简单，有sql经验的同学应该都知道drop就是删除掉某个对象，例如某个数据库或者某个表。在flink table sql中drop支持的类型有：#drop多...

在前面的文章《Flink应用开发系列（五十三）Table SQL开发之自定义UDF函数》和《Flink应用开发系列（五十四）Table SQL开发之自定义UDAF函数》我们分别介绍了一下udf和udaf函数相关的开发...

在前面我们介绍过雪花id相关的文章《java分布式项目之使用雪花算法生成唯一id》和《java分布式项目之使用tinyid生成唯一id》。在实际的生产环境中，我们会涉及到一些订单的场景，此时生成的订单号一般我们都会以...

上一篇文章《Flink应用开发系列（五十三）Table SQL开发之自定义UDF函数》我们介绍了UDF函数的开发，本文的话我们再介绍下UDAF函数的开发。在UDF里面，它是给定一个值，然后会返回一个值。但是在UDAF...

在上一篇文章《Flink应用开发系列（五十二）Table SQL开发之create function》我们介绍了创建function，在文章里面我们提过这里的函数主要是UDF，UDAF，UDTF等函数，所以本文的话，...

在这里function的话，其实就是我们使用的UDF,UDTF,UDAF等函数。有时候在一些特定的场景里面，我们需要在查询的时候做某些数据类的操作，但是flink这样的table sql里面没有相关的函数可用，所以这...

在使用传统的mysql的时候，我们知道还有一个视图的东西，也就是view，这种视图一般作为临时连接多张表或者跨库的时候使用的中间表有时候可以让我们少写一些代码，提升了查询数据的便利性。在flink table sql...

前面我们介绍过在flink中，整个table sql的结构是：${catalog}.${database}.${table}。这里的database其实就是数据库，和我们日常理解的数据库是一个意思。在flink ta...