把hive 表stu77 的數據寫入 mysql 表test_stu 中. 中間可以加自己的邏輯. ...

Flink批處理與hbase的讀寫 source-hbase 父類 是模仿官方寫的. 子類 sink-hbase ...

AdPojo{channel='朋友圈', subject='英語', refer='H5', reg='100', ord='100', pv='100', uv='100'} ...

一、DataSet API之Data Sources（消費者之數據源） 介紹： flink提供了大量的已經實現好的source方法，你也可以自定義source 通過實現sourceFunction接口來自定義無並行度的source， 或者你也可以通過實現 ...

一、環境准備 本機環境：jdk11、scala2.12、maven3.6 新建一個maven項目，pom如下 項目結構如下 1、添加scala源文件，新建一個scala的文件夾， ...

一、寫數據 　　向Hive中寫數據只嘗試了流數據寫入Hive，畢竟批數據寫入數倉的場景並不多，Flink 1.11對於Hive流處理的支持還是改善很多的，用起來也很方便。 　　1、可以直接將流數據轉換為Table寫入hive（測試環境下采用文件寫入DataStream，再轉換為Table ...

-----------更新說明---------- 突然就想水一篇博客，剛好說明一下這段時間基本沒有更新的問題。 簡單介紹下我的職業生涯，大家有留意的話，可以在博客園上看到，我的博客是從20 ...

一、flink在批處理中常見的source 　　flink在批處理中常見的source主要有兩大類: 　 　　　　1.基於本地集合的source（Collection-based-source） 　　 　　　　2.基於文件的source（File-based-source ...