org.apache.hadoop.mapreduce.lib.join.CompositeInputFormat#org.apache.hadoop.mapreduce.lib.join.TupleWritable源码实例Demo

下面列出了org.apache.hadoop.mapreduce.lib.join.CompositeInputFormat#org.apache.hadoop.mapreduce.lib.join.TupleWritable 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: hiped2   文件: CompositeJoin.java
@Override
protected void map(Text key, TupleWritable value, Context context)
    throws IOException, InterruptedException {
  context.write(key,
      new Text(StringUtils.join(value.get(0), value.get(1))));
}