通过Java代码创建hbase表的二级索引表的demo

很高兴为您解答问题！以下是通过Java代码创建HBase表的二级索引表的示例：

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;

import java.io.IOException;

public class HBaseIndexTableDemo {

    public static final String HBASE_CONF_PATH = "/etc/hbase/conf/hbase-site.xml";
    public static final String TABLE_NAME = "my_table";
    public static final String INDEX_TABLE_NAME = TABLE_NAME + "_index";
    public static final String COLUMN_FAMILY = "cf";
    public static final String INDEX_COLUMN_FAMILY = "index_cf";
    public static final String INDEX_QUALIFIER = "my_index";

    public static void main(String[] args) throws IOException {
        Configuration conf = HBaseConfiguration.create();
        conf.addResource(HBASE_CONF_PATH);

        Connection conn = ConnectionFactory.createConnection(conf);
        Admin admin = conn.getAdmin();

        // Create main table
        HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(TABLE_NAME));
        HColumnDescriptor cfDesc = new HColumnDescriptor(COLUMN_FAMILY);
        tableDesc.addFamily(cfDesc);
        admin.createTable(tableDesc);

        // Create index table
        HTableDescriptor indexTableDesc = new HTableDescriptor(TableName.valueOf(INDEX_TABLE_NAME));
        HColumnDescriptor indexCfDesc = new HColumnDescriptor(INDEX_COLUMN_FAMILY);
        indexTableDesc.addFamily(indexCfDesc);
        admin.createTable(indexTableDesc);

        // Add data to main table
        Table table = conn.getTable(TableName.valueOf(TABLE_NAME));
        Put put = new Put("row_key".getBytes());
        put.addColumn(cfDesc.getName(), "column_qualifier".getBytes(), "column_value".getBytes());
        table.put(put);

        // Add index to index table
        Table indexTable = conn.getTable(TableName.valueOf(INDEX_TABLE_NAME));
        Put indexPut = new Put("index_key".getBytes());
        indexPut.addColumn(indexCfDesc.getName(), INDEX_QUALIFIER.getBytes(), "row_key".getBytes());
        indexTable.put(indexPut);

        conn.close();
    }
}

希望这可以帮助到您！