Flinksql window triggered in advance

scene ： The window of the day , Want to trigger every minute or other time point

insert into sliding_window_local_pay_day
select userid,
  TUMBLE_START (ptime, INTERVAL '1' DAY) as window_start,
  TUMBLE_END (ptime, INTERVAL '1' DAY) as window_end,
  COUNT (1) as pay_num
from
  flink_kafka_join_pay
group by TUMBLE (ptime, INTERVAL '1' DAY), userid;

1. Two parameters ： Every minute

table.exec.emit.early-fire.enabled: 'true'
table.exec.emit.early-fire.delay: 60s 

2. Triggering in the source code means generating Trigger

Generate Trigger The logic of is window aggregation key The first data time point +N individual Interval, It's different key The trigger time is different

 /**
     * Creates a trigger that fires by a certain interval after reception of the first element.
     *
     * @param time the certain interval
     */
    public static <W extends Window> AfterFirstElementPeriodic<W> every(Duration time) {
        return new AfterFirstElementPeriodic<>(time.toMillis());
    }

3. Trigger effect , Different userid, The trigger time is different