在Flink中，使用event-time模式時，默認(rèn)提供的window有TumblingEventTimeWindows，SlidingEven...
投稿
收錄了124篇文章 · 5人關(guān)注
-
Flink中EventTimeTrigger的理解
-
Phoenix創(chuàng)建Hbase二級索引
1. Phoenix簡介 1.1 Phoenix定義 Phoenix是HBase的開源SQL皮膚?？梢允褂脴?biāo)準(zhǔn)JDBC API代替HBase客戶...
-
es 寫入數(shù)據(jù)的工作原理是什么??？es 查詢數(shù)據(jù)的工作原理是什么?。康讓拥?lucene 介紹一下唄？倒排 索引了解嗎？面試官心理分析 問這個，其實面試官就是要看看你了解不了解 es 的一些基本原理，因為用 es 無非就是寫入數(shù)據(jù)，搜索數(shù)據(jù)。你要是不明白你發(fā)起一個...
-
Apache Paimon 在同程旅行的探索實踐摘要：本文主要介紹 Apache Paimon 在同程旅行的生產(chǎn)落地實踐經(jīng)驗。在同程旅行的業(yè)務(wù)場景下，通過使用 Paimon 替換 Hudi，實...
-
Flink：背壓，busy time和延遲之間的關(guān)系探究
1. Back Pressure（背壓）在算子層面上很好理解，背壓的出現(xiàn)代表下游的消費者的消費速度小于上游生產(chǎn)者的生產(chǎn)速度；但實際上在Flink...
-
kafka有序性
1 為什么只保證單partition有序 如果Kafka要保證多個partition有序，不僅broker保存的數(shù)據(jù)要保持順序，消費時也要按序消...
-
Spark讀寫HBase實踐
Spark經(jīng)常會讀寫一些外部數(shù)據(jù)源，常見的有HDFS、HBase、JDBC、Redis、Kafka等。這些都是Spark的常見操作，做一個簡單的...
-
PySpark Dataframe寫入ES、Redis
一、Dataframe寫入Elasticsearch 1.1 依賴 根據(jù)實際使用的spark版本及ES版本選擇合適的包，在提交任務(wù)時指定--pa...
-
Flink鏈路延遲測量的LatencyMarker機制實現(xiàn)前言 今天本應(yīng)放一首適合高考?xì)夥盏母璧?，但是既然受疫情影響推遲了，還是老老實實寫點技術(shù)相關(guān)的吧。 對于實時的流式處理系統(tǒng)來說，我們需要關(guān)注數(shù)據(jù)輸...
-
FeatHub：流批一體的實時特征工程平臺摘要：本文整理自阿里巴巴高級技術(shù)專家、Apache Flink/Kafka PMC 林東，在 FFA 2022 AI 特征工程專場的分享。本篇內(nèi)...
{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1881139527',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://upload.jianshu.io/collections/images/601852/Penguins.jpg', '推薦專題《大數(shù)據(jù)》（ 分享自 @簡書 ）','http://www.itdecent.cn/c/aa0e76874148?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','頁面編碼gb2312|utf-8默認(rèn)gb2312'));){kind=link}