Flink大数据实时计算系列-第一个程序JAVA版本-分组统计 lambda写法

Flink大数据实时计算系列-第一个程序JAVA版本-分组 lambda写法

在基线版本上增加了分组统计的代码（lambda写法）

Flink代码

package com.flinkniu.flink.operator;

import org.apache.flink.api.common.typeinfo.Types;
import org.apache