• 多襄丸
    2020-10-17
    TumblingCountWindow 应该是用的 CountEvictor的吧。 想象了一种不太恰当的 DeltaEvictor 使用场景 既然DeltaEvictor 可以是任何一种计算方式，如果以人体温作为数据源，那我是不是可以在process之前 drop掉 体温 < 36度的数据(可能是测量仪问题)？
    共 1 条评论
    1
  • 会飞的企鹅
    2022-04-05
    TopSpeedWindowing用我scala实现的的时候遇到一个问题： .evictor(TimeEvictor.of(Time.of(evictorTime * 1000, TimeUnit.MILLISECONDS)) 会报这个错误 Type mismatch. Required: Evictor[_ >: CarEvent, _ >: GlobalWindow], found: TimeEvictor[Nothing] 但是运行又能跑起来
    
    
  • 汪林林
    2022-03-11
    geektime-Flink-master.zip 的代码 如何用 idea能跑起来，张老师帮忙解答下。
    
    
  • Allan
    2021-03-01
    DeltaEvictor 变量增强？意思就是计算窗口中差距的值是在我们指定的值（threshold）之内的意思？是否理解正确？
    
    