Flink最大的亮點(diǎn)是實(shí)時(shí)處理部分,F(xiàn)link認(rèn)為批處理是流處理的特殊情況,可以通過一套引擎處理批量和流式數(shù)據(jù),而Flink在未來也會(huì)重點(diǎn)投入更...
投稿
收錄了5篇文章 · 2人關(guān)注
Flink最大的亮點(diǎn)是實(shí)時(shí)處理部分,F(xiàn)link認(rèn)為批處理是流處理的特殊情況,可以通過一套引擎處理批量和流式數(shù)據(jù),而Flink在未來也會(huì)重點(diǎn)投入更...
窗口是流式計(jì)算中非常常用的算子之一,通過窗口可以將無限流切分成有限流,然后在每個(gè)窗口之上使用計(jì)算函數(shù),可以實(shí)現(xiàn)非常靈活的操作。Flink提供了豐...
當(dāng)我們?cè)谑褂肍link的時(shí)候,避免不了要和時(shí)間(time)、水位線(watermarks)打交道,理解這些概念是開發(fā)分布式流處理應(yīng)用的基礎(chǔ)。那么...
Flink是一個(gè)分布式的流處理引擎,而流處理的其中一個(gè)特點(diǎn)就是7X24。那么,如何保障Flink作業(yè)的持續(xù)運(yùn)行呢?Flink的內(nèi)部會(huì)將應(yīng)用狀態(tài)(...
Flink 提供了專門的 Kafka 連接器,向 Kafka topic 中讀取或者寫入數(shù)據(jù)。Flink Kafka Consumer 集成了 ...