一、DataStream API之Data Sources（消費者之數據源） 介紹： source是程序的數據源輸入，你可以通過StreamExecutionEnvironment.addSource(sourceFunction)來為你的程序添加一個source。 flink提供了大量的已經 ...

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

　　隨着大數據技術在各行各業的廣泛應用，要求能對海量數據進行實時處理的需求越來越多，同時數據處理的業務邏輯也越來越復雜，傳統的批處理方式和早期的流式處理框架也越來越難以在延遲性、吞吐量、容錯能力以及使用便捷性等方面滿足業務日益苛刻的要求。 在這種形勢下，新型流式處理框架Flink通過創造性地 ...

...

一、高性能Flink SQL優化技巧 1、Group Aggregate優化技巧 開啟MicroBatch或MiniBatch（提升吞吐） MicroBatch和MiniBatch都是微批處理，只是微批的觸發機制略有不同。原理同樣是緩存一定的數據后再觸發處理，以減少對State的訪問 ...

Flink 面試--進階篇 1、Flink是如何支持批流一體的？ 2、Flink是如何做到高效的數據交換的？ 3、Flink是如何做容錯的？ 4、Flink 分布式快照的原理是什么 ...

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

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