栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

HBase Java API基本增删改查操作

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

HBase Java API基本增删改查操作

1、安装Hbase

【前提是已经安装好了Hadoop】
解压:tar -xvf hbase-1.4.0-bin.tar.gz

重命名:mv hbase-1.4.0 hbase

在/etc/profile中配置环境变量:
export Hbase_HOME=/usr/local/hbase
export PATH=$PATH:$Hbase_HOME/bin
使环境变量立即生效:source /etc/profile

配置hbase-env.sh:
修改下面的两处配置:
export JAVA_HOME=/usr/local/jdk
export Hbase_MANAGES_ZK=true

配置hbase-site.sh:


        
                hbase.rootdir
                hdfs://hadoop001:9000/hbase
        
        
                hbase.cluster.distributed
                true
        
        
                hbase.zookeeper.quorum
                hadoop001
        

/etc/hosts需要增加服务器内网与映射的主机名为hadoop001。

然后启动hbase,./start-hbase.sh,发现有一个错误,

然后我将value改为服务器内网地址。


        hbase.zookeeper.quorum
        172.19.232.251

再次运行,发现可以了诶。

使用jps命令查看hbase相关进程,

发现hbase的3个进程全部启动了,说明安装成功了。

可以使用hbase shell命令,进入hbase shell命令行,进行相关操作。

2、创建表 命令

create 表名,列族

Java实现
public class CreateTable {
    public static void main(String[] args) throws Exception {
        //获取配置文件
        Configuration configuration = HbaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum","服务器公网:2181");

        //创建连接
        Connection connection = ConnectionFactory.createConnection(configuration);
        Admin admin = connection.getAdmin();

        //定义表名
        TableName tableName = TableName.valueOf("mytable");
        //定义表
        HTableDescriptor table = new HTableDescriptor(tableName);
        //定义列族
        HColumnDescriptor mycf = new HColumnDescriptor("mycf");
        table.addFamily(new HColumnDescriptor(mycf));

        //执行创建表的动作
        admin.createTable(table);

        admin.close();
        connection.close();
    }
}


注意:

  • 在Windows中需要在hosts文件中添加服务器公网ip以及映射的服务器主机名
  • 相关端口需要开通
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/530538.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号