src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/BoundedOutOfOrdernessGeneratorPerQueue.java [61:68]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public String toString() {
        return "BoundedOutOfOrdernessGeneratorPerQueue{"
                + "maxEventTimeTable="
                + maxEventTimeTable
                + ", maxOutOfOrderness="
                + maxOutOfOrderness
                + '}';
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/org/apache/flink/connector/rocketmq/legacy/common/watermark/WaterMarkPerQueue.java [56:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public String toString() {
        return "WaterMarkPerQueue{"
                + "maxEventTimeTable="
                + maxEventTimeTable
                + ", maxOutOfOrderness="
                + maxOutOfOrderness
                + '}';
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -