Flink系列文章

Flink系列文章

1 概念

  • Flink学习1-基础概念
  • 浅析背压(Back Pressure)机制及其在 Spark & Flink中的实现

2 安装和配置

  • Flink学习2-安装和启动

3 使用

3.1 概览

  • Flink学习3-API介绍

3.2 DataStream

3.2.1 概览

  • Flink-DataStream-HDFSConnector(StreamingFileSink)
  • HDFS租约与Flink StreamingFileSink
  • Flink学习-DataStream-KafkaConnector

3.2.2 例子

  • Flink-StreaimingFileSink-自定义序列化-Parquet批量压缩
  • Flink-使用rowtime且分窗,Connector读取Kafka写入MySQL例子

3.3 Table&Sql API

  • Flink学习4-流式SQL
  • Flink-流式SQL源码分析
  • Flink-时间窗口源码分析

4 流平台

  • Flink-流平台调研
  • Flink-Zeppelin On FlinkSql

5 Flink和其他技术

  • HDFS租约与Flink StreamingFileSink
  • Flink-Zeppelin On FlinkSql

6 常见问题

  • Flink学习6-常见问题

7 新特性

  • Flink 1.10.0

8 源码

8.1 源码编译

  • 官网-Building Flink from Source
  • Flink 源码解析 —— 源码编译运行
    来自阿里大佬zhisheng_blog
  • Flink源码编译部署Flink
    简单明了
  • Flink 1.10源代码编译,基于Flink release-1.10分支
    mvn clean install -T 2C -Dfast -Dmaven.compile.fork=true -DskipTests -Dscala-2.11快速编译

8.2 源码解析

你可能感兴趣的