前言 本文是兩個(gè)月前參加黑馬比賽時(shí)寫了一半的,為了避免爛尾琅翻,今天補(bǔ)全發(fā)出來放钦。 Flink CDC經(jīng)過長(zhǎng)時(shí)間的發(fā)展渣磷,目前無疑是實(shí)現(xiàn)數(shù)據(jù)源端Pipeline的最簡(jiǎn)單直接的方式擂仍。而...
前言 本文是兩個(gè)月前參加黑馬比賽時(shí)寫了一半的,為了避免爛尾琅翻,今天補(bǔ)全發(fā)出來放钦。 Flink CDC經(jīng)過長(zhǎng)時(shí)間的發(fā)展渣磷,目前無疑是實(shí)現(xiàn)數(shù)據(jù)源端Pipeline的最簡(jiǎn)單直接的方式擂仍。而...
Timer簡(jiǎn)介 Timer(定時(shí)器)是Flink Streaming API提供的用于感知并利用處理時(shí)間/事件時(shí)間變化的機(jī)制辛燥。Ververica blog上給出的描述如下: ...
Parquet調(diào)研報(bào)告 1. 概述 1.1 簡(jiǎn)介 Apache Parquet是Hadoop生態(tài)圈中一種新型列式存儲(chǔ)格式,它可以兼容Hadoop生態(tài)圈中大多數(shù)計(jì)算框架(Had...