hbase预分区

语法

create \'t1\', \'f1\', SPLITS => [\'10\', \'20\', \'30\', \'40\']
create \'t1\', \'f1\', SPLITS_FILE => \'splits.txt\', OWNER => \'johndoe\'
# Optionally pre-split the table into NUMREGIONS, using
# SPLITALGO ("HexStringSplit", "UniformSplit" or classname)
create \'t1\', \'f1\', {NUMREGIONS => 15, SPLITALGO => \'HexStringSplit\'}
create \'t1\', \'f1\', {NUMREGIONS => 15, SPLITALGO => \'HexStringSplit\', REGION_REPLICATION => 2, CONFIGURATION => {\'hbase.hregion.scan.loadColumnFamiliesOnDemand\' => \'true\'}}

　　hbase shell实现

create \'fei\', {NAME =>\'f\'}, SPLITS => [ \'1\', \'2\', \'3\',\'4\',\'5\',\'6\',\'7\',\'8\',\'9\']

效果

scala代码实现

将hbase-site.xml放到resources目录

import org.apache.hadoop.conf.Configuration
import org.apache.hadoop.hbase.client.{ColumnFamilyDescriptorBuilder, ConnectionFactory, TableDescriptorBuilder}
import org.apache.hadoop.hbase.util.Bytes
import org.apache.hadoop.hbase.{HBaseConfiguration, TableName}

object HbaseCreate {
  def main(args: Array[String]): Unit = {
    //读取hbase-site.xml的方式创建hbaseConf
    val hbaseConf = HBaseConfiguration.create(new Configuration())
    val connection = ConnectionFactory.createConnection()
    val admin = connection.getAdmin();
    val tableName = TableName.valueOf("afei")
    //如果有表就删除
    if (admin.tableExists(tableName)) {
      admin.disableTable(tableName)
      admin.deleteTable(tableName)
    }
    val tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)

    val columnDescBuilder = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes("f"))
    columnDescBuilder.setMaxVersions(3)

    tableDescriptor.setColumnFamily(columnDescBuilder.build)

    //预分区
    /* val splitKeys = Array( Bytes.toBytes("1"), Bytes.toBytes("2"), Bytes.toBytes("3"), Bytes.toBytes("4"), Bytes.toBytes("5"),
       Bytes.toBytes("6"), Bytes.toBytes("7"), Bytes.toBytes("8"), Bytes.toBytes("9"))*/
    var splitKeys: List[Array[Byte]] = List()
    for (x <- 1 to 9) {
      if(x<10){
        splitKeys = splitKeys.+:(Bytes.toBytes(x.toString))
      }else{
        splitKeys = splitKeys.+:(Bytes.toBytes(x.toString))
      }

    }

    //创建表
    admin.createTable(tableDescriptor.build(), splitKeys.toArray)

    admin.close()
    connection.close()

    println("创建完成")
  }

}