码迷,mamicode.com
首页 > 编程语言 > 详细

Java 中如何对 Iterator<Text> values 实现两次遍历

时间:2016-03-17 07:07:16      阅读:205      评论:0      收藏:0      [点我收藏+]

标签:

Just like this!!!!!!!!!!!!!!!!

===============================================================

 public static class Reduce extends MapReduceBase implements
  Reducer<IntWritable, Text, NullWritable, Text> {
 
    @Override
    public void reduce(IntWritable dummy, Iterator<Text> values,
        OutputCollector<NullWritable, Text> output, Reporter reporter)
            throws IOException { 
    	
    	List<Text> cache = new ArrayList<Text>();

    	// first loop and caching   
    	while (values.hasNext()) {
    		 
    	   cache.add(new Text(values.next()));
    		  
    	}
    	 
    	// second loop 
    	for(Text p:cache) {
    	 
           output.collect(NullWritable.get(), p);
       	 
    	} 
      
    }
  }  


Java 中如何对 Iterator<Text> values 实现两次遍历

标签:

原文地址:http://blog.csdn.net/yaoxiaochuang/article/details/50910204

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!