Flink Trigger实例
1、需求：统计每天的人员出现次数，按天开窗，并且每10s进行一次输出。import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner;import org.apache.flink.api.common.eventtime.WatermarkStrategy;import org.apache.flink.api.common.functions.MapFunction;import org.apache.fl
