在flink中，当我在接口AscendingTimestampExtractor()中使用assignTimestampsAndWatermarks()时，..i收到弃用消息

public class MyAssigner implements AssignerWithPeriodicWatermarks<Event> {

    private long currentTimestamp = Long.MIN_VALUE;

    @Override
    public long extractTimestamp(Event event, long previousTimestamp) {
        long timestamp = event.getTimestamp();
        currentTimestamp = Math.max(timestamp, currentTimestamp);
        return timestamp;
    }

    @Override
    public Watermark getCurrentWatermark() {
        return new Watermark(currentTimestamp - 1000); // 生成水印的逻辑
    }
}

public class MyAssigner implements AssignerWithPunctuatedWatermarks<Event> {

    @Override
    public long extractTimestamp(Event event, long previousTimestamp) {
        return event.getTimestamp();
    }

    @Override
    public Watermark checkAndGetNextWatermark(Event event, long extractedTimestamp) {
        if (event.getType() == EventType.END) {
            return new Watermark(extractedTimestamp); // 根据事件特征生成水印的逻辑
        }
        return null;
    }
}