hbase,false是单机模式
环境安装
HBASE安装
运行
开启服务
start-hbase.sh
查看版本:
hbase version
jps:
能看到HMaster
web端访问:16010
Hbase shell
对hbase的表的理解,在mysql的基础上,在列的基础上多了列簇,列簇是列的集合;存储数据的数据结构是map,key是时间戳,val才是真正的值
命名空间:命名空间相当于myslq的库
表操作
数据操作
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 HbaseConn { public static void main(String[] args) throws IOException { // 创建配置文件 Configuration conf = HBaseConfiguration.create(); // 从zookeeper的管理中调用hbase conf.set("hbase.zookeeper.quorum", "192.168.137.122"); // 创建连接 Connection conn = ConnectionFactory.createConnection(conf); // 获取Admin对象:可以对表进行操作 Admin admin = conn.getAdmin(); // 判断表是否存在,如果不存在则会创建,如果存在则删除 // 表名: my_ns:my_054yxd TableName tableName = TableName.valueOf("my_ns:stu"); if (admin.tableExists(tableName)){ System.out.println("存在表"); // 1.判断表是否启用 boolean state = admin.isTableEnabled(tableName); System.out.println(tableName + (state?"启用":"禁用")); // 2.如果启用就禁用 if (state){ admin.disableTable(tableName); } // 3.禁用之后删除 admin.deleteTable(tableName); System.out.println("删除成功"); }else { System.out.println("不存在"); // todo 不存在则创建表 // 创建表 TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(tableName); // 创建列簇 ColumnFamilyDescriptor cfd = ColumnFamilyDescriptorBuilder .newBuilder("info".getBytes()).build(); // 设置列簇 builder.setColumnFamily(cfd); // 构建表结构 TableDescriptor table = builder.build(); // 创建 admin.createTable(table); // 4.判断是否创建成功 System.out.println( admin.tableExists(tableName) ? "创建成功" : "创建失败"); } } }
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。