设为首页 加入收藏

TOP

Hbase数据库操作工具类
2019-02-12 13:37:13 】 浏览:31
Tags:Hbase 数据库 操作 工具
版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/shujuelin/article/details/83546407
package com.it18zhang.test;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

/**
 * 操作hbase的工具类
 */
public class HbaseUtils {
    
    HBaseAdmin admin = null;
    Configuration configration = null;

    /**
     * 私有构造方法
     */
    private HbaseUtils(){
        configration = new Configuration();
        configration.set("hbase.master","135.0.97.29:60000");
        configration.set("hbase.zookeeper.quorum","135.0.97.31:2181,135.0.97.32:2181,135.0.97.33:2181");

        try {
            admin = new HBaseAdmin(configration);
        } catch (IOException e) {
            e.printStackTrace();

        }
    }

    private static HbaseUtils instance = null;
    
    public static synchronized HbaseUtils getInstance(){
        if(null == instance){
            instance = new HbaseUtils();

        }
        return instance;

    }

    /**
     * 根据表名获取到 Htable 实例
     */
    public HTable getTable(String tableName){
        HTable table = null;
        try {
            table = new HTable(configration,tabl
		    

eName); } catch (IOException e) { e.printStackTrace(); } return table; } /** * 添加一条记录到 Hbase 表 70 30 128 32 核 200T 8000 * @param tableName Hbase 表名 * @param rowkey Hbase 表的 rowkey * @param cf Hbase 表的 columnfamily列族 * @param column Hbase 表的列 * @param value 写入 Hbase 表的值 */ public void put(String tableName,String rowkey,String cf,String column,String value){ HTable table = getTable(tableName); Put put = new Put(Bytes.toBytes(rowkey)); put.add(Bytes.toBytes(cf),Bytes.toBytes(column),Bytes.toBytes(value)); try { table.put(put); } catch (IOException e) { e.printStackTrace(); } } /** * 得到所有的数据 * @param tableName * @throws IOException */ public void getAllRows(String tableName) throws IOException { HTable table = getTable(tableName); //得到用于扫描region的对象 Scan scan = new Scan(); //使用HTable得到resultcanner实现类的对象 ResultScanner resultScanner = table.getScanner(scan); for (Result result : resultScanner) { Cell[] cells = result.rawCells(); for (Cell cell : cells) { //得到rowkey System.out.println(Bytes.toString(CellUtil.cloneRow(cell))); //得到列族 System.out.println(Bytes.toString(CellUtil.cloneFamily(cell))); System.out.println(Bytes.toString(CellUtil.cloneQualifier(cell))); System.out.println(Bytes.toString(CellUtil.cloneva lue(cell))); } } } public static void main(String[] args) throws IOException { //HTable table = HBaseUtils.getInstance().getTable("category_clickcount"); //System.out.println(table.getName().getNameAsString()); String tableName = "user_activity"; /* String rowkey = "20171122_1"; String cf="info"; String column ="click_count"; String value = "2";*/ HbaseUtils.getInstance().getAllRows(tableName); } }


编程开发网
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇Hbase部分常用的封装类 下一篇java对hbase的增删改查操作

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

array(4) { ["type"]=> int(8) ["message"]=> string(24) "Undefined variable: jobs" ["file"]=> string(32) "/mnt/wp/cppentry/do/bencandy.php" ["line"]=> int(217) }