在Flink中,使用event-time模式時,默認(rèn)提供的window有TumblingEventTimeWindows,SlidingEven...
投稿
在Flink中,使用event-time模式時,默認(rèn)提供的window有TumblingEventTimeWindows,SlidingEven...
1. Phoenix簡介 1.1 Phoenix定義 Phoenix是HBase的開源SQL皮膚??梢允褂脴?biāo)準(zhǔn)JDBC API代替HBase客戶...
面試官心理分析 問這個,其實面試官就是要看看你了解不了解 es 的一些基本原理,因為用 es 無非就是寫入數(shù)據(jù),搜索數(shù)據(jù)。你要是不明白你發(fā)起一個...
摘要:本文主要介紹 Apache Paimon 在同程旅行的生產(chǎn)落地實踐經(jīng)驗。在同程旅行的業(yè)務(wù)場景下,通過使用 Paimon 替換 Hudi,實...
1. Back Pressure(背壓)在算子層面上很好理解,背壓的出現(xiàn)代表下游的消費者的消費速度小于上游生產(chǎn)者的生產(chǎn)速度;但實際上在Flink...
1 為什么只保證單partition有序 如果Kafka要保證多個partition有序,不僅broker保存的數(shù)據(jù)要保持順序,消費時也要按序消...
Spark經(jīng)常會讀寫一些外部數(shù)據(jù)源,常見的有HDFS、HBase、JDBC、Redis、Kafka等。這些都是Spark的常見操作,做一個簡單的...
一、Dataframe寫入Elasticsearch 1.1 依賴 根據(jù)實際使用的spark版本及ES版本選擇合適的包,在提交任務(wù)時指定--pa...
前言 今天本應(yīng)放一首適合高考?xì)夥盏母璧?,但是既然受疫情影響推遲了,還是老老實實寫點技術(shù)相關(guān)的吧。 對于實時的流式處理系統(tǒng)來說,我們需要關(guān)注數(shù)據(jù)輸...
摘要:本文整理自阿里巴巴高級技術(shù)專家、Apache Flink/Kafka PMC 林東,在 FFA 2022 AI 特征工程專場的分享。本篇內(nèi)...