在以下代码中:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
SingleOutputStreamOperator<Tuple2<String, Integer>> dataStream = env.fromElements(
Tuple2.of("01", 1),
Tuple2.of("02", 2),
Tuple2.of("03", 3),
Tuple2.of("04", 4),
Tuple2.of("05", 5)
).assignTimestampsAndWatermarks(
WatermarkStrategy.<Tuple2<String, Integer>>forMonotonousTimestamps()
.withTimestampAssigner(
(tuple, ts) -> System.currentTimeMillis()));
env.execute("dfjghf")
env.execute("gghh");
Flink-1.17.1， Java 11
在这条有界的溪流中将注入多少水印？是五点吗？
2) 如何打印这些水印元素？只是为了调试.