发简信
IP属地：浙江
-
使用Docker搭建伪分布式Hbase(外置Zookeeper)
本文是为了记录项目搭建一个可用的 Hbase镜像的过程，由于项目中还有独立的kafka和zookeeper， 所以不能使用常见的集成zk的Hba...
-
使用Docker部署Flink大数据项目本文是为基于Flink的商品推荐系统所搭建的Docker环境，目的为了方便体验项目，一键部署项目需要的所有环境，并预填充所需要的数据。完整的环境...
-
flink使用16-正确打包Flink程序并使用Cli提交任务
本文的计划是使用正确的maven插件打包当前教程代码库batch模块下的WordCount代码，并通过命令行的方式提交到Flink来启动任务。W...
-
使用Docker部署Kafka时的网络应该如何配置本文是我在使用Docker部署kafka遇到一些问题之后，在网上看到的一篇比较优秀的英文资料Link。借此翻译一下这篇文章，也帮助自己搞懂在使用...
-
flink使用15-在Flink SQL中连接kafka和mysql
本文主要介绍如何使用 FLink SQL 自己的 DDL语言来构建基于 kafka 的表和 基于Mysql 的表，并直接把从 kafka 接过来...
-
flink使用14-使用SQL操作几种window
Flink SQL 支持三种窗口类型, 分别为 Tumble Windows / HOP Windows 和 Session Windows. ...
-
flink使用13-开始体验 Flink SQL
SQL API 是 Flink 中最顶级的 API , 它构建了 Table API 之上, 也可以方便的和 Table 做转换, 构建 SQL...
-
flink使用12-用 table API 实现WordCount
Table API 是 Flink 构建在 DataSet 和 DataStream API 之上的一套结构化编程接口. 本文希望通过一个简单的...
-
flink使用11-了解broadcast的用法
在Flink中，同一个算子可能存在若干个不同的并行实例，计算过程可能不在同一个Slot中进行，不同算子之间更是如此，因此不同算子的计算数据之间不...