MySQL是一種關系型數據庫，而HBase是一種NoSQL數據庫，兩者的數據存儲結構不同，但在某些場景下我們需要將MySQL中的數據遷移到HBase中。下面我們將介紹如何實現MySQL數據遷移到HBase。

首先，我們需要安裝并配置HBase和MySQL數據庫的驅動程序，以便在Java中處理它們的連接和查詢。我們也需要安裝HBase的Java API和HBase的客戶端端口。

1.安裝HBase和MySQL數據庫驅動程序：
sudo apt-get install hbase
sudo apt-get install mysql-connector-java
2.添加HBase Java API：
hadoop fs -put /usr/lib/hbase/hbase-protocol.jar /hbase/lib/hbase-protocol.jar
3.安裝HBase的客戶端端口：
sudo apt-get update
sudo apt-get install hbase-master
sudo apt-get install hbase-client

接下來我們需要創建一個Java應用程序來實現數據遷移。我們先需要連接到MySQL數據庫，并對表執行SELECT查詢。然后，我們將使用Java API將結果轉換為KeyValue格式，并將其插入到HBase表中。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
public class MysqlToHbase {
public static void main(String[] args) {
String driver = "com.mysql.jdbc.Driver";
String url = "jdbc:mysql://localhost:3306/test";
String username = "username";
String password = "password";
Connection con = null;
Statement stmt = null;
ResultSet rs = null;
try {
Class.forName(driver);
con = DriverManager.getConnection(url, username, password);
stmt = con.createStatement();
String sql = "SELECT * FROM t_user";
rs = stmt.executeQuery(sql);
Configuration conf = HBaseConfiguration.create();
Connection connection = ConnectionFactory.createConnection(conf);
HTable table = new HTable(conf, "user");
while (rs.next()) {
String rowkey = rs.getString("id");
Put p = new Put(Bytes.toBytes(rowkey));
p.add(Bytes.toBytes("info"), Bytes.toBytes("name"), Bytes.toBytes(rs.getString("name")));
p.add(Bytes.toBytes("info"), Bytes.toBytes("age"), Bytes.toBytes(rs.getString("age")));
table.put(p);
}
System.out.println("Data imported into HBase table");
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (rs != null)
rs.close();
if (stmt != null)
stmt.close();
if (con != null)
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}

在運行此代碼之前，我們需要創建并在HBase中創建`user`表。我們可以使用以下命令來創建一個名為`user`的表：

create 'user', {NAME =>'info'}

最后，我們需要在Java應用程序中指定HBase的連接信息，包括ZooKeeper的地址和端口號：

Configuration conf = HBaseConfiguration.create();
conf.set("hbase.zookeeper.quorum", "localhost");
conf.set("hbase.zookeeper.property.clientPort", "2181");
Connection connection = ConnectionFactory.createConnection(conf);
HTable table = new HTable(conf, "user");

這樣，我們就可以將MySQL中的數據遷移到HBase了。