public class HBaseInsertDemo {
    public static void main(String[] args) throws Exception {
        // 配置HBase
        Configuration conf = HBaseConfiguration.create();
        config.set("hbase.client.tdsql.quorum", "10.10.10.10:6752");    // HBase服务RPC端口
        config.setBoolean("hbase.tdsql.hash.partition", Boolean.TRUE); // 启用HBase兼容模式
        config.set("mysql.native.username", "test");                   // 数据库用户名
        config.set("mysql.native.password", "test123");                // 数据库密码

        Connection connection = ConnectionFactory.createConnection(conf);

        // 拿到Table句柄
        TableName tableName = TableName.valueOf("ht1");
        Table table = connection.getTable(tableName);

        // 准备插入数据
        Put put = new Put(Bytes.toBytes("rk801"));
        put.addColumn(Bytes.toBytes("cf1"), Bytes.toBytes("column1"), Bytes.toBytes("v1")); // 列族，列标识符，值
        table.put(put);

        // 关闭资源
        table.close();
        connection.close();

        System.out.println("数据插入成功!");
    }
}