Hbase|Hbase 预分区建表 Hbase预分区建表

![](https://upload-images.jianshu.io/upload_images/9028759-735db08803d91f7c.png?imageMogr2/auto-orient/strip%7CimageView2/2/w/1240)
```
private static Admin admin = null;
private static final String user = "admin/admin@DEMO.COM";
private static final String keyPath = "/etc/security/keytabs/admin.keytab";
static {
System.setProperty("java.security.krb5.conf", "/etc/krb5.conf");
System.setProperty("sun.security.krb5.debug", "false");
Configuration conf = new Configuration();
conf.addResource("hbase-site.xml");
【Hbase|Hbase 预分区建表】conf.set("hbase.zookeeper.quorum", "storm4.demo.com,storm2.demo.com,storm3.demo.com");
conf.set(HConstants.ZOOKEEPER_CLIENT_PORT, "2181");
conf.set(HConstants.ZOOKEEPER_ZNODE_PARENT, "/hbase-secure");
conf.set("hbase.security.authentication", "kerberos");
conf.set("hadoop.security.authentication", "kerberos");
UserGroupInformation.setConfiguration(conf);
try {
UserGroupInformation.loginUserFromKeytab(user, keyPath);
} catch (IOException e) {
e.printStackTrace();
}
Connection connection= null;
try {
connection = ConnectionFactory.createConnection(conf);
} catch (IOException e) {
e.printStackTrace();
}
try {
admin = connection.getAdmin();
} catch (IOException e) {
e.printStackTrace();
}
}
public synchronized static Table getTable(String tableName) {
try {
return TABLE_MAP.get(tableName);
} catch (ExecutionException e) {
e.printStackTrace();
}
return null;
}
public synchronized static void createTable(String tableName) throws HBaseException {
TableName table = TableName.valueOf(tableName);
TableDescriptorBuilder tableDesc = TableDescriptorBuilder.newBuilder(table)
tableDesc.setValue(TableDescriptorBuilder.SPLIT_POLICY, classOf[DelimitedKeyPrefixRegionSplitPolicy].getName)
tableDesc.setValue(DelimitedKeyPrefixRegionSplitPolicy.DELIMITER_KEY, "|") //以|作为分区前缀
ColumnFamilyDescriptor extCF = ColumnFamilyDescriptorBuilder.newBuilder("ext".getBytes()).setTimeToLive("90 DAYS").build();
ColumnFamilyDescriptor deviceCF = ColumnFamilyDescriptorBuilder.newBuilder("device".getBytes()).setTimeToLive("90 DAYS").build();
ColumnFamilyDescriptor locationCF = ColumnFamilyDescriptorBuilder.newBuilder("location".getBytes()).setTimeToLive("90 DAYS").build();
tableDesc.setColumnFamilies(Arrays.asList(extCF, locationCF, deviceCF));
try {
val regionServers = 8
val splitKeys = (0 until 256 by regionServers).map(Integer.toHexString).map(i => s"0$i".takeRight(2)).map(Bytes.toBytes).toArray
admin.createTable(tableDesc.build(), splitKeys); //预分区
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
try {
createTable("DSP_LOG_TABLE");
} catch (HBaseException e) {
e.printStackTrace();
}
}
```

Hbase|Hbase 预分区建表

推荐阅读

苏若禹对林书豪凶狠犯规后,在网上被球迷们谩骂侮辱,书豪出面为他解围,你怎么评价？

芒果可以和酸奶同吃吗芒果可以和酸奶同吃吗

HTML常见标签用法

Win10系统下mmc控制台关闭按钮不见了怎么办？

节食减肥有用吗明显如何减肥，减肥多久能看出来瘦了

养生保健归根到底多吃五谷

今日猪肉水产价格「国内猪肉价格今日价」

红碎茶茶色的科学分析

酸菜鱼香豆腐的做法酸菜鱼香豆腐的做法是什么

申通正在派件的快递多久到货

运行出现博世冰箱声音大怎么解决？

鳕鱼猪血粥——补气养血促进大脑发育

腮腺炎的预防措施有哪些？腮腺炎的预防针有必要打吗

阳光房顶棚遮阳帘

林内壁挂炉显示e4,小松鼠壁挂炉e4故障怎么处理

idea怎么写javafx，myeclipse2014 怎么弄javafx

休要丢人现眼打一字休要丢人现眼打一字谜打一字

兄弟打印机怎么清零7080-兄弟7080d更换墨粉盒怎么清零

战双帕弥什渡边好吗战双帕弥什渡边使用技巧

孕晚期感觉燥热是男孩孕妇为什么热