FlinkFlink 的输出 Output CountingOutput

Posted 2021-09-08 九师兄

1.概述

这点为何和watermark有关，这一点我也是无意之间看到的，在研究flink watermark的时候，watermark传播的时候需要Output 输出到下游。

CountingOutput这个是输出类的包装类。可以看到构造函数传入了一个Output<StreamRecord<OUT>> output

public class CountingOutput<OUT> implements Output<