pi数据库转存hbase

将Pi数据库中的数据转存到HBase需要经过以下几个步骤：

1. 安装HBase和Pi数据库，并保证两者都能正常运行。

2. 创建HBase表，定义表结构。

3. 编写Java代码，实现数据的读取和写入。首先需要连接Pi数据库，然后从Pi数据库中读取数据，将数据转换为HBase表中的格式，最后写入HBase表。

4. 执行Java代码，将数据从Pi数据库转存到HBase中。

下面是一个简单的Java代码示例，可以将Pi数据库中的数据转存到HBase中：

import java.sql.*;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.*;

public class PiToHBase {
    public static void main(String[] args) {
        // 连接Pi数据库
        Connection piConn = DriverManager.getConnection("jdbc:pi://hostname:port/database", "username", "password");
        Statement piStmt = piConn.createStatement();
        ResultSet piRs = piStmt.executeQuery("SELECT * FROM table");

        // 连接HBase
        Configuration conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "hostname");
        Connection hbaseConn = ConnectionFactory.createConnection(conf);
        Admin admin = hbaseConn.getAdmin();

        // 创建HBase表
        String tableName = "table";
        HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(tableName));
        tableDesc.addFamily(new HColumnDescriptor("family"));
        admin.createTable(tableDesc);

        // 将数据写入HBase表
        Table hbaseTable = hbaseConn.getTable(TableName.valueOf(tableName));
        while (piRs.next()) {
            Put put = new Put(Bytes.toBytes(piRs.getString("rowkey")));
            put.addColumn(Bytes.toBytes("family"), Bytes.toBytes("col1"), Bytes.toBytes(piRs.getString("col1")));
            put.addColumn(Bytes.toBytes("family"), Bytes.toBytes("col2"), Bytes.toBytes(piRs.getString("col2")));
            hbaseTable.put(put);
        }

        // 关闭连接
        hbaseTable.close();
        admin.close();
        hbaseConn.close();
        piRs.close();
        piStmt.close();
        piConn.close();
    }
}

其中，需要将Pi数据库的连接信息、HBase的连接信息、表名称、列族名称和列名称等信息修改为实际情况。