flink1.9.1 学习笔记

• Flink1.9.1,jdk.1.8,scala2.11
• 开发环境：window 10、Cygwin64 Terminal
• https://opensourceteams.github.io/flink-example-all
• https://github.com/opensourceteams/flink-example-all
• 微博: https://weibo.com/thinktothings

Flink 基础

Flink 数据流编程模型

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_001_data_flow_programming_model

Flink 分布式运行环境

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_002_distributed_runtime_environment

Flink本地模式安装

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_003_local_setup_tutorial

Flink 项目模板java版

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_004_maven_project_template_for_java

Flink 项目模板scala版

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_005_maven_project_template_for_scala

window 操作系统dos 命令提交 Flink 作业

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_006_dos_command_submit_flink_job

Linux 操作系统 命令提交 Flink 作业

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_007_linux_command_submit_flink_job

Flink 命令

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_008_flink_command

Flink 组件

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-common/n_009_flink_component

---

Flink Scala版 (Streaming)

disable OperatorChaining (禁用算子合并)

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-scala/n_001_streaming_disable_OperatorChaining

Flink streaming api source 方式

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-scala/n_002_streaming_api_DataSources

---

Flink java版 (Streaming)

flink1.9.1 java版初体验(Java版)

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-java/n_001_wordcount_local_nc

---

Flink 官网示例

flink streaming WordCount for java

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-official/n_001_example_socketWindowWordCount_java

flink batch WordCount for java

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-official/n_002_batch_wordcount_java

flink batch WordCount for scala

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-official/n_003_batch_wordCount_scala

flink streaming WordCount for scala

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-official/n_004_streaming_wordCount_scala

---

其它

window 常用命令

• https://github.com/opensourceteams/flink-example-all/blob/master/md/window.md

Cygwin 路径转换

• https://github.com/opensourceteams/flink-example-all/blob/master/md/cygwin.md

图片md 链接

• https://github.com/opensourceteams/flink-example-all/blob/master/md/image.md

scala mysql jdbc(增、删、改、查)

• https://github.com/opensourceteams/flink-example-all/tree/master/flink-example-other/n_001_scala_mysql

---