flink-demo-根据事件时间触发窗口计算

1.数据： 目标： 使用的api 代码实现 1. 生产者 2. 消费者 测试 1.启动 2.输入 3.输出 1.数据： 事件的格式为　abc,3,20180503-110301java abc:统计的key值 3: key值的个数 20180503-110301: 事件时间戳 目标： 使用kafka存储产生的事件，而后用flink进行消费，采用flink的窗口机制，根据事件的时间戳，当两个事件的时

>>阅读原文<<