logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink实时计算topN热榜

topN的常见应用场景,最热商品购买量,最高人气作者的阅读量等等。1. 用到的知识点1.Flink创建kafka数据源;2.基于 EventTime 处理,如何指定 Watermark;3.Flink中的Window,滚动(tumbling)窗口与滑动(sliding)窗口;4.State状态的使用;5.ProcessFunction 实现 TopN 功能;2. 案例介绍通过用户访问日志,计算最近

#flume#sqoop#flink
ElasticSearch原理+实战知识点

今天为大家带来流计算领域经常使用的组件 ElasticSearch,本文通过原理+实战操教程带领大家快速学会 ElasticSearch 搜索引擎,以下内容全部经过实战操作,可以根据文档进行学习~大纲如下:1 ElasticSearch 概述1.1 全文搜索引擎小伙伴们经常使用 google 或者百度进行搜索内容,在输入框中输入关键字,这个时候,网站会将包含 关键字 的所有网页返回,大家有没有想过

#sqoop#flink#scala
到底了