阅读量:2
在HBase中创建表结构需要使用HBase Shell或HBase Java API。
使用HBase Shell创建表结构的步骤如下:
- 打开HBase Shell。
- 使用
create
命令创建表,指定表名和列族。例如:create 'mytable', 'cf1', 'cf2'
。 - 可选地,使用
alter
命令修改表的属性,如最大版本数、过期时间等。例如:alter 'mytable', {NAME=>'cf1', VERSIONS=>5}
。
使用HBase Java API创建表结构的示例代码如下:
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.io.compress.CompressionAlgorithm; import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; import org.apache.hadoop.hbase.regionserver.BloomType; public class CreateTableExample { public static void main(String[] args) throws Exception { Configuration config = HBaseConfiguration.create(); try (Connection connection = ConnectionFactory.createConnection(config); Admin admin = connection.getAdmin()) { TableName tableName = TableName.valueOf("mytable"); TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName) .setColumnFamily(ColumnFamilyDescriptorBuilder.of("cf1")) .setColumnFamily(ColumnFamilyDescriptorBuilder.of("cf2")) .build(); admin.createTable(tableDescriptor); } } }
以上是创建HBase表结构的基本步骤,可以根据需要进行表属性的设置和修改。