实现复制val counts = visits .keyBy("region") .timeWindow(Time.hours(1)) .sum("visits")  1.