@Override
protected void reduce(Text key, Iterable<IntWritable> values, Context context) throws IOException, InterruptedException {
int count=0;
Iterator<IntWritable> iterator= values.iterator();
//<1,1,1>
while (iterator.hasNext()){
IntWritable value = iterator.next();
count += value.get();
}
}
(1) 方法iterator():要求容器返回一个Iterator。
(2) 使用next()获得序列中的下一个元素。
(3) 使用hasNext()检查序列中是否还有元素。
(4) 使用remove()将迭代器新返回的元素删除。
发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/206794.html原文链接:https://javaforall.net