首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
flinksql
相关资讯
热门
最新
后端
01-01 08:00
后端
FlinkSQL中的回退更新-Retraction
FlinkSQL中的回退更新-Retraction,群主王知无大数据技术与架构前言如果你在使用FlinkSQL时出现如下的报错:Tableisnotanappend-onlytable.UsethetoRetractStream()inordertohandleaddandretractmessages.那么你就有必要了解一下Flink中的回退更新。简介通俗的讲"回退更新"就是传统数据里面的更新操
176
后端
01-01 08:00
后端
FlinkSQL使用自定义UDTF函数行转列-IK分词器
FlinkSQL使用自定义UDTF函数行转列-IK分词器,一、背景说明本文基于IK分词器,自定义一个UDTF(TableFunctions),实现类似Hive的explode行转列的效果,以此来简明开发过程。如下图Flink三层API接口中,TableAPI的接口位于最顶层也是最易用的一层,可以套用SQL语法进行代码编写,对于有SQL基础的能很快上手,但是不足之处在于灵活度有限,自有函数不能满足使
169
后端
01-01 08:00
后端
FlinkSQL使用自定义UDTF函数行转列-IK分词器
FlinkSQL使用自定义UDTF函数行转列-IK分词器,FlinkSQL使用自定义UDTF函数行转列-IK分词器一、背景说明本文基于IK分词器,自定义一个UDTF(TableFunctions),实现类似Hive的explode行转列的效果,以此来简明开发过程。如下图Flink三层API接口中,TableAPI的接口位于最顶层也是最易用的一层,可以套用SQL语法进行代码编写,对于有SQL基础的能
147
后端
01-01 08:00
后端
FlinkSQL写入Kafka/ES/MySQL示例-JAVA
FlinkSQL写入Kafka/ES/MySQL示例-JAVA,FlinkSQL写入Kafka/ES/MySQL示例-JAVA一、背景说明Flink的API做了4层的封装,上两层TableAPI、SQL语法相对简单便于编写,面对小需求可以快速上手解决,本文参考官网及部分线上教程编写source端、sink端代码,分别读取socket、kafka及文本作为source,并将流数据输出写入Kafka、
134
后端
01-01 08:00
后端
FlinkSQL元数据验证
Flink1.9以后引入CatalogManager来管理Catalog和CatalogBaseTable,在执行DDL语句时将表信息封装为CatalogBaseTable存储在CatalogMan...
122
后端
01-01 08:00
后端
FlinkSQL内置了这么多函数你都使用过吗?
FlinkSQL内置了这么多函数你都使用过吗?,前言FlinkTable和SQL内置了很多SQL中支持的函数;如果有无法满足的需要,则可以实现用户自定义的函数(UDF)来解决。一、系统内置函数FlinkTableAPI和SQL为用户提供了一组用于数据转换的内置函数。SQL中支持的很多函数,TableAPI和SQL都已经做了实现,其它还在快速开发扩展中。以下是一些典型函数的举例,全部的内置函数,可以
111
后端
01-01 08:00
后端
FlinkSQL内置了这么多函数你都使用过吗?
前言 Flink Table 和 SQL 内置了很多 SQL 中支持的函数;如果有无法满足的需要,则可以实现用户自定义的函数(UDF)来解决。 一、系统内置函数 Flink Table API ...
103
后端
01-01 08:00
后端
FlinkSQL元数据验证
FlinkSQL元数据验证,Flink1.9以后引入CatalogManager来管理Catalog和CatalogBaseTable,在执行DDL语句时将表信息封装为CatalogBaseTable存储在CatalogManager中。同时扩展了calcite的Schema接口使得Calcite在Validate阶段能够读取CatalogManager中的表信息。CatalogTable写入通过
102
后端
01-01 08:00
后端
FlinkSQL元数据验证
Flink1.9以后引入CatalogManager来管理Catalog和CatalogBaseTable,在执行DDL语句时将表信息封装为CatalogBaseTable存储在CatalogMan...
96
后端
01-01 08:00
后端
FlinkSQL元数据验证
Flink1.9以后引入CatalogManager来管理Catalog和CatalogBaseTable,在执行DDL语句时将表信息封装为CatalogBaseTable存储在CatalogMan...
76
«
1
2
»