Flink 自定义trigger
自定义trigger的主要目的是为了等待数据到齐:代码如下; flink版本1.6public class WatermarkTest { public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvir...
