日期:2014-05-16  浏览次数:20750 次

mapreduce处理结果向输出至mysql(直接插入/更新/追加式更新)

Mapreduce处理结果向输出至mysql

?

1.写入mysql

<1>job中输出的配置:

DBOutputFormat.setOutput(this, MySQLConstant.MYSQL_FIX_USER,

MySQLConstant.MYSQL_FIX_OPEN_FIRST_FIELDS);

(DBOutputFormathadoop自带API,将输入插入数据库)

public?final?static?String