Flink 自定义Trigger实战代码，结合State来使用

简单说明： 比如window大小为20秒，在进入window的时候 有一个valueState在统计数据数量，数量大于等于2的时候直接触发这个窗口，如果在20秒事件窗口内只有一条数据进入 那么正常等window事件到了 就会触发这一条数据了 。  package appOperator; import com.alibaba.fastjson.JSONObject; import org.apa

>>阅读原文<<