flink sql指定rowtime和proctime的几种方式

    CREATE TABLE tt_stream (
      a VARCHAR,
      b VARCHAR,
      ts TIMESTAMP,
      WATERMARK wk1 FOR ts as withOffset (ts, 1000) --Watermark计算方法。
    ) WITH ();
    
    
    AI写代码sql

    // 这是认为没有乱序的数据，水位线的生成 
    stream.assignTimestampsAndWatermarks(WatermarkStrategy.<ResInfo>forMonotonousTimestamps().withTimestampAssigner(new SerializableTimestampAssigner<ResInfo>() {
            @Override
            public long extractTimestamp(ResIn