發(fā)簡信
IP屬地：重慶
-
使用Docker搭建偽分布式Hbase(外置Zookeeper)
本文是為了記錄項目搭建一個可用的 Hbase鏡像的過程，由于項目中還有獨立的kafka和zookeeper， 所以不能使用常見的集成zk的Hba...
-
使用Docker部署Flink大數(shù)據(jù)項目本文是為基于Flink的商品推薦系統(tǒng)所搭建的Docker環(huán)境，目的為了方便體驗項目，一鍵部署項目需要的所有環(huán)境，并預(yù)填充所需要的數(shù)據(jù)。完整的環(huán)境...
-
flink使用16-正確打包Flink程序并使用Cli提交任務(wù)
本文的計劃是使用正確的maven插件打包當(dāng)前教程代碼庫batch模塊下的WordCount代碼，并通過命令行的方式提交到Flink來啟動任務(wù)。W...
-
使用Docker部署Kafka時的網(wǎng)絡(luò)應(yīng)該如何配置本文是我在使用Docker部署kafka遇到一些問題之后，在網(wǎng)上看到的一篇比較優(yōu)秀的英文資料Link。借此翻譯一下這篇文章，也幫助自己搞懂在使用...
-
flink使用15-在Flink SQL中連接kafka和mysql
本文主要介紹如何使用 FLink SQL 自己的 DDL語言來構(gòu)建基于 kafka 的表和 基于Mysql 的表，并直接把從 kafka 接過來...
-
flink使用14-使用SQL操作幾種window
Flink SQL 支持三種窗口類型, 分別為 Tumble Windows / HOP Windows 和 Session Windows. ...
-
flink使用13-開始體驗 Flink SQL
SQL API 是 Flink 中最頂級的 API , 它構(gòu)建了 Table API 之上, 也可以方便的和 Table 做轉(zhuǎn)換, 構(gòu)建 SQL...
-
flink使用12-用 table API 實現(xiàn)WordCount
Table API 是 Flink 構(gòu)建在 DataSet 和 DataStream API 之上的一套結(jié)構(gòu)化編程接口. 本文希望通過一個簡單的...
-
flink使用11-了解broadcast的用法
在Flink中，同一個算子可能存在若干個不同的并行實例，計算過程可能不在同一個Slot中進行，不同算子之間更是如此，因此不同算子的計算數(shù)據(jù)之間不...