下面列出了org.apache.hadoop.mapreduce.lib.join.CompositeInputFormat#org.apache.hadoop.mapreduce.lib.join.TupleWritable 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
@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))));
}