在Flink中，使用event-time模式时，默认提供的window有TumblingEventTimeWindows，SlidingEven...
投稿
收录了124篇文章 · 5人关注
-
Flink中EventTimeTrigger的理解
-
Phoenix创建Hbase二级索引
1. Phoenix简介 1.1 Phoenix定义 Phoenix是HBase的开源SQL皮肤。可以使用标准JDBC API代替HBase客户...
-
es 写入数据的工作原理是什么啊？es 查询数据的工作原理是什么啊？底层的 lucene 介绍一下呗？倒排 索引了解吗？面试官心理分析 问这个，其实面试官就是要看看你了解不了解 es 的一些基本原理，因为用 es 无非就是写入数据，搜索数据。你要是不明白你发起一个...
-
Apache Paimon 在同程旅行的探索实践摘要：本文主要介绍 Apache Paimon 在同程旅行的生产落地实践经验。在同程旅行的业务场景下，通过使用 Paimon 替换 Hudi，实...
-
Flink：背压，busy time和延迟之间的关系探究
1. Back Pressure（背压）在算子层面上很好理解，背压的出现代表下游的消费者的消费速度小于上游生产者的生产速度；但实际上在Flink...
-
kafka有序性
1 为什么只保证单partition有序 如果Kafka要保证多个partition有序，不仅broker保存的数据要保持顺序，消费时也要按序消...
-
Spark读写HBase实践
Spark经常会读写一些外部数据源，常见的有HDFS、HBase、JDBC、Redis、Kafka等。这些都是Spark的常见操作，做一个简单的...
-
PySpark Dataframe写入ES、Redis
一、Dataframe写入Elasticsearch 1.1 依赖 根据实际使用的spark版本及ES版本选择合适的包，在提交任务时指定--pa...
-
Flink链路延迟测量的LatencyMarker机制实现前言 今天本应放一首适合高考气氛的歌的，但是既然受疫情影响推迟了，还是老老实实写点技术相关的吧。 对于实时的流式处理系统来说，我们需要关注数据输...
-
FeatHub：流批一体的实时特征工程平台摘要：本文整理自阿里巴巴高级技术专家、Apache Flink/Kafka PMC 林东，在 FFA 2022 AI 特征工程专场的分享。本篇内...
专题公告
大数据相关
{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', '推荐专题《大数据》（ 分享自 @简书 ）','https://wsa.jianshu.io/c/aa0e76874148?utm_campaign=maleskine&utm_content=collection&utm_medium=reader_share&utm_source=weibo','页面编码gb2312|utf-8默认gb2312'));){kind=link}