Flink 自定义Trigger
需求，滑动窗口统计，keyby下过来一条就触发窗口统计，如果没消息过来，按30s触发一次窗口。只能自定义Trigger直接上代码import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONObject;import com.tc.flink.conf.KafkaConfig;import org.apache.fli...
