MapReduce讀寫mysql

hadoop的API提供了DBOutputFormat和DBInputFormat這兩個類，來進行與數據庫交互，除此以外，咱們還須要定義一個相似JAVA Bean的實體類，來與數據庫的每行記錄進行對應，一般這個類要實現Writable和DBWritable接口，來重寫裏面的4個方法以對應獲取每行記錄裏面的各個字段信息。

參考：

http://blog.csdn.net/aaa1117a8w5s6d/article/details/37603311

http://www.iteye.com/topic/1133716

更多MapReduce實例：

http://my.oschina.net/itblog/blog/275294?fromerr=yfYjsFxl

http://www.aboutyun.com/thread-15605-1-1.html

http://www.cnblogs.com/xia520pi/archive/2012/06/04/2534533.html

針對那個多表關聯，我認爲能夠設計成key value地址編號——工廠名，地址編號——地址名；最後分組的時候天然分在一塊兒了，把value合併一下就好了，我的思路，僅供你們參考