Flink定时器怎么实现

背景需求

在电商领域会有这么一个场景，如果用户买了商品，在订单完成之后，24小时之内没有做出评价，系统自动给与五星好评，我们今天主要使用flink的定时器来简单实现这一功能。

案例详解

自定义source

首先我们还是通过自定义source来模拟生成一些订单数据.
在这里，我们生了一个最简单的二元组Tuple2,包含订单id和订单完成时间两个字段.

 public static class MySource implements SourceFunction>{
  private volatile boolean isRunning = true;

  @Override
  public void run(SourceContext> ctx) throws Exception{
   while (isRunning){
    Thread.sleep(1000);
    //订单id
    String orderid = UUID.randomUUID().toString();
    //订单完成时间
    long orderFinishTime = System.currentTimeMillis();
    ctx.collect(Tuple2.of(orderid, orderFinishTime));
   }
  }

  @Override
  public void cancel(){
   isRunning = false;
  }
 }

定时处理逻辑

先上代码, 我们再来依次解释代码

 public static class TimerProcessFuntion
   extends KeyedProcessFunction,Object>{

  private MapState mapState;
  //超过多长时间(interval,单位：毫秒) 没有评价，则自动五星好评
  private long interval = 0l;

  public TimerProcessFuntion(long interval){
   this.interval = interval;
  }

  @Override
  public void open(Configuration parameters){
   MapStateDescriptor mapStateDesc = new MapStateDescriptor<>(
     "mapStateDesc",
     String.class, Long.class);
   mapState = getRuntimeContext().getMapState(mapStateDesc);
  }

  @Override
  public void onTimer(
    long timestamp, OnTimerContext ctx, Collector