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