List<Tuple2<String, Integer>> output = counts.collect();
for (Tuple2<?, ?> tuple : output) {
System.out.println(tuple._1() + " : " + tuple._2());
}
ctx.stop();
}
}
安装部署与运行实例(2)
内容版权声明:除非注明,否则皆为本站原创文章。
转载注明出处:https://www.heiqu.com/24cfee8087dd4f0442b0e974797f2167.html