logo
介绍
环境配置
博客
开源项目
AI
阿里
CNCF
面试大全
FAQ
简体中文
English
2026
2025
2024
2023
GitHub
介绍
环境配置
博客
开源项目
AI
阿里
CNCF
面试大全
FAQ
简体中文
English
2026
2025
2024
2023
GitHub
logo
概览

Java

概览
Mybatis
Spring

MySQL

概览

Redis

概览

Kafka

概览

Flink

概览

文档

反压
概念
文档
内存管理

实践

DataStream 和 SQL 互转
案例
Flink SQL Gateway

group

人群圈选
快速开始
Flink Redis Connector
行列转换
Flink SQL
窗口函数

DevOps

index

面试题

通用
Flink
Flink SQL

CEP

概览
概念
动态 Cep
Json
规则引擎

风控

概览

Project

概览

Paimon

概览
概念
主键表
实践
参数
Action
Example

Gravitino

概览
快速开始
Flink 生态
数据血缘

Doris

后端数据归档

catalog

Paimon
概览
标签
窗口函数

ODPS

概览

SQL

备份
基础
DDL
函数
行列转换
SelectDB
Admin

数仓

维度建模
概览
湖仓

practice

paimon

Doris
ODS
实战项目
起源
Variant 类型

问题定位

经验案例
概览

#人群圈选

#去重

涉及到去重时计算 UV,Flink 不像离线计算那样高效,它需要在状态中缓存大量数据进行去重,长周期、大数据量下去重耗费资源过多。

现有 Flink 去重方式有如下几种:

  • HashMap/Set或MapState。将数据存入 HashMap/Set 或 MapState 中
  • HyperLogLog
  • BitMap

#参考资料

  • 实时计算中的精确去重:RoaringBitmap 原理剖析与 Flink 落地全过程
  • Flink通过BITMAP类型实现精确去重
    • BITMAP 位图函数
  • Doris
    • SQL 类型 BITMAP
    • SQL 函数 BITMAP函数

Last Updated: 2026/8/28 02:31:17

📝 在 GitHub 上编辑此页
上一篇Flink SQL Gateway
下一篇快速开始
目录
  • 去重
  • 参考资料