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 预分区建表

推荐阅读

绮字五行属什么绮的组词

电线如何选择几方电线选2.5方还是4方

怎么才能把金牛座的男生追到手？

尼康fm2常见问题尼康FM2怎么启动电源

烤鸭架子汤怎么做好吃

qq空间怎么设置仅自己可见

百度网盘Svip如何购买便宜百度网盘vip共享

国际和平日手抄报文字国际宽容日手抄报内容

无症状感染者|广州新疫情传播力强，市民通宵排队打疫苗，专家：10天后可产生保护力

让你的打印机重获新生佳能MG6150废墨清零方法详解

新手开网店怎样开呢网店怎么样

核桃仁冷冻了三年还能吃吗

菲斯曼壁挂炉怎么调水压？

acl会议含金量,acl2023什么时候出结果

三角战略试玩版队友怎么招募三角战略试玩版队友招募方法

世界足球日小孩踢足球简笔画

郑州公租房在等待分房期间居住证换地址有影响吗？

如何正确清洗羽绒服？

iphone13第一次充电注意事项

一花一世界|一花一世界|小说连载