前言 之前的文章中已經(jīng)屢次提到過Flink的事件時(shí)間（event time）、水印（watermark）、亂序（out-of-order）、遲到數(shù)據(jù)（late element...
發(fā)簡(jiǎn)信
IP屬地：青海
-
再談Flink事件時(shí)間、水印和遲到數(shù)據(jù)處理 -
【Spark系列】spark中job，stage，task之間的關(guān)系1.什么是job Job簡(jiǎn)單講就是提交給spark的任務(wù)。 2.什么是stage Stage是每一個(gè)job處理過程要分為的幾個(gè)階段。 3.什么是task Task是每一個(gè)jo...
-
Spark優(yōu)化https://blog.csdn.net/u012102306/article/details/51322209#commentBox https://blog.csdn....
-
spark-streaming-kafka之createDirectStream模式
完整工程用例 最近一直在用directstream方式消費(fèi)kafka中的數(shù)據(jù)，特此總結(jié)，整個(gè)代碼工程分為三個(gè)部分一. 完整工程代碼如下(某些地方特意做了說明, 這個(gè)代碼的部...
