Flink sql 是什么 ❝ sql 的诞生就是为了简化我们对数据开发,可以使用少量的 sql 代码,帮助我完成对数据的查询,分析等功能 ❞ 声明式 & 易于理解 对于用户只需要表达我想要什么,具体处理逻...

Flink的Transformation转换主要包括四种：单数据流基本转换、基于Key的分组转换、多数据流转换和数据重分布转换。读者可以使用Flink Scala Shell或者Intellij Idea来进行练习：Flink Scala Shel...

前言：前段时间因为项目需求，需要开发一个实时采集分析日志的任务，最后选择的计算框架是Flink。项目完成后，基本上就没再接触。但总觉得既然用过了，不了解，不清楚，日后又需要还得重新看，...

Flink的安装和部署主要分为本地（单机）模式和集群模式，其中本地模式只需直接解压就可以使用，不用修改任何参数，一般在做一些简单测试的时候使用。本地模式在我们的课程里面不再赘述。集群模...

原标题：大厂高频：Flink分区分配策略 目前Flink包含8个重分区算子，对应8个分区器（7个官方定义及1个自定义），均继承与父类StreamPartitioner。以下带大家了解Flink的各种分区策略。 1. Rebal...

雷锋网 AI 科技评论按：日前，Josh Gordon 在 TensorFlow 官网上发布了一篇博 雷锋网 AI 科技评论按：日前，Josh Gordon 在 TensorFlow 官网上发布了一篇博客，详细介绍了符号式 API（symbolic ...