
4篇文章 · 4899字 · 10人關(guān)注
1. 程序和數(shù)據(jù)流 Flink程序構(gòu)建的基本單元是stream和transformation(請(qǐng)注意,DataSet實(shí)質(zhì)上也是stream)如捅。一...
1. 前言 1.1 說明 本文通過一個(gè)Demo程序,演示Flink從Kafka中讀取數(shù)據(jù),并將數(shù)據(jù)以JDBC的方式持久化到關(guān)系型數(shù)據(jù)庫中缸榄。通過本...
1. 部署說明 Flink 有三種部署模式,分別是 Local祝拯、Standalone Cluster 和 Yarn Cluster甚带。對(duì)于 Loc...
本文是學(xué)習(xí)Apache Flink的開始,記錄了Flink Local模式的部署佳头,并運(yùn)行了Word Count例子鹰贵。 1.下載和部署。 Flin...