Add first(n) to Flink GroupReduce Example