flink视频教程学习笔记


视频地址

视频地址

基础定义

有界/无界数据流

有状态计算

例如:过去一段时间的点击量
状态可持久化

时间官网

  • 事件发生时间
  • 事件进入flink时间
  • flink处理事件时间

API

3层API

应用场景

  • Data Pipeline
  • Data Analytics
  • Data Driven

flink - maven构建项目命令

mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-java -DarchetypeVersion=1.10.0

文章作者: wuzhiyong
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 wuzhiyong !
评论
 上一篇
flink典型应用场景 flink典型应用场景
flink应用场景Apache Flink 功能强大,支持开发和运行多种不同种类的应用程序。它的主要特性包括:批流一体化、精密的状态管理、事件时间支持以及精确一次的状态一致性保障等。Flink 不仅可以运行在包括 YARN、 Mesos、K
2020-03-12
下一篇 
kafka单机版部署 kafka单机版部署
下载kafka在官网下载kafka最新版本。 如:当前最新2.4.0,针对Scala不同版本有不同的编译包,下载Scala 2.12的测试。 wget http://mirrors.tuna.tsinghua.edu.cn/apache/k
2020-03-03
  目录