240 发简信
IP属地:澳门
  • 使用Docker搭建伪分布式Hbase(外置Zookeeper)

    本文是为了记录项目搭建一个可用的 Hbase镜像的过程,由于项目中还有独立的kafka和zookeeper, 所以不能使用常见的集成zk的Hba...

  • Resize,w 360,h 240
    使用Docker部署Flink大数据项目

    本文是为基于Flink的商品推荐系统所搭建的Docker环境,目的为了方便体验项目,一键部署项目需要的所有环境,并预填充所需要的数据。完整的环境...

  • flink使用16-正确打包Flink程序并使用Cli提交任务

    本文的计划是使用正确的maven插件打包当前教程代码库batch模块下的WordCount代码,并通过命令行的方式提交到Flink来启动任务。W...

  • Resize,w 360,h 240
    使用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中进行,不同算子之间更是如此,因此不同算子的计算数据之间不...

个人介绍
大数据工程师 / Flink初学者