Hadoop 連接mysql


1   

mysql數據導入到hdfs數據

      hadoop提供了org.apache.hadoop.io.Writable接口來實現簡單的高效的可序列化的協議,該類基於DataInput和DataOutput來實現相關的功能。

     hadoop對數據庫訪問也提供了org.apache.hadoop.mapred.lib.db.DBWritable接口,其中write方法用於對PreparedStatement對象設定值,readFields方法用於對從數據庫讀取出來的對象進行列的值綁定;

見  https://blog.csdn.net/lianggangzzu/article/details/72594186

見  https://blog.csdn.net/fantasticqiang/article/details/80667023

 

2

hdfs數據導入到mysql

    hdfs文件存儲到mysql,也需要上邊的DBRecord類作為輔助,因為數據庫的操作都是通過DBInput和DBOutput來進行的;


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM