flink统计

Question

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

Answer 1

Michael_PK 2020-10-14 12:12:11

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

• 提问者 qq_金融超越战_03665934 #1

  关键是datastream按照不同纬度去统计后，分别是datastream1.datastream2这2个流通过datastream1.connect(datastream2).flatMap时，没有计算出结果来。不懂这里面的原理。

• Michael_PK 回复 提问者 qq_金融超越战_03665934 #2

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

Answer 2

提问者 qq_金融超越战_03665934 2020-10-14 12:18:25

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

• Michael_PK #1

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