• 热门专题

按字段分组的Reducer

作者:  发布日期:2016-03-07 20:38:22
Tag标签:字段  
  • /***
     * @author YangXin
     * @info 按字段分组的Reducer
     */
    package unitTwelve;
    
    import java.io.IOException;
    
    import org.apache.hadoop.io.Text;
    import org.apache.hadoop.mapreduce.Reducer;
    
    public class ByKeyReducer extends Reducer<Text, Text, Text, Text> {
    	protected void reduce(Text key, Iterable<Text> values, Context context) throws IOException, InterruptedException{
    		StringBuilder output = new StringBuilder();
    		for(Text value : values){
    			output.append(value.toString()).append(" ");
    		}
    		context.write(key, new Text(output.toString().trim()));
    	}
    }
    
About IT165 - 广告服务 - 隐私声明 - 版权申明 - 免责条款 - 网站地图 - 网友投稿 - 联系方式
本站内容来自于互联网,仅供用于网络技术学习,学习中请遵循相关法律法规