Timer簡(jiǎn)介 Timer（定時(shí)器）是Flink Streaming API提供的用于感知并利用處理時(shí)間/事件時(shí)間變化的機(jī)制。Ververica blog上給出的描述如下： ...
發(fā)簡(jiǎn)信
IP屬地：浙江
-
Flink Timer（定時(shí)器）機(jī)制與其具體實(shí)現(xiàn) -
Flink 1.12 Hive分區(qū)時(shí)態(tài)表批流一體需求背景 我們生產(chǎn)常有將實(shí)時(shí)與Hive維表join來(lái)豐富數(shù)據(jù)的需求、Hive表是分區(qū)表、上周Flink 1.12發(fā)布了、剛好支撐了這種業(yè)務(wù)場(chǎng)景王暗、我也將1.12版本部署了、做了...
-
Flink Iceberg 0.11背景 我們?cè)谑褂肍link+Kafka做實(shí)時(shí)數(shù)倉(cāng)以及數(shù)據(jù)傳輸過(guò)程中，遇到了一些問(wèn)題蝶怔，Iceberg 0.11的新特性解決了這些業(yè)務(wù)場(chǎng)景，基于Iceberg我們做了一些實(shí)踐兄墅，對(duì)...
-
