flink统计

来源：9-4 Flink Standalone模式部署及参数详解

qq_金融超越战_03665934

2020-10-14

请假老师一个问题，如果我用flink去统计10分钟内，request请求数返回200的总数，返回401的总数。我应该怎么写呀。我的意思是不分开写，想一个窗口统计多份数据。

写回答

2回答

Michael_PK

2020-10-14

拿到一个datasteam后，基于这个datastream可以多任意维度的统计分析呢。过滤出来，或者使用side output都可以

Michael_PK

qq_金融超越战_03665934

首先拿到datastream，然后不同纬度不就是在datastream中的基础进行不同的计算不就可以吗

2020-10-15

共2条回复

qq_金融超越战_03665934

提问者

2020-10-14

老师，我目前就是拿到datastream.然后分2个纬度统计一个统计200的总数，一个统计401的总数，然后根据用户id把他们join在一起。这个思路没问题吧?

Michael_PK

每个指标出来不是单独存放的么，咋还需要union？如果业务是这样的，也没啥问题

2020-10-14

共1条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势，多语言系统化讲解，极速入门Flink

969 学习 · 296 问题

相似问题

回答 1

回答 1

回答 1

回答 4

回答 1