habse入门级别的笔记(摘抄)

Posted 踏雪飞虹

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了habse入门级别的笔记(摘抄)相关的知识,希望对你有一定的参考价值。

最最常用的指令:

1.查看hbase有什么表 list

2.创建一个表: create ‘表名‘, ‘字段1’, ‘字段二’,。。。

3.往表中插入一条数据:put ‘表名‘,‘rowkey’,‘字段一:’,‘字段一栏目一名称’,‘字段一栏目一’,.....

4.查看整个表某列的内容:scan ‘表名‘,‘行名称’,‘列名称’

5.获得某行记录:get ‘表名’,‘rowkey‘

6.查看表中记录总数:count ‘表名‘

 

调用hbase接口应该注什么?

1.初始化配置(如):

  Configuration conf = new Configuration();

  conf.set("hbase.zookeeper.quorum", "10.XXX.1.XXX,10.XXX.XXX.43,10.XXX.XXX.44"); 
  conf.set("hbase.rootdir", "hdfs://10.XXX.4.XXX:9000/user/hbase");
  conf.set("hbase.cluster.distributed", "true");
  conf.set("hbase.zookeeper.property.clientPort", "XXX");
  conf.set("hbase.master.port", "XXX");
  conf.set("hbase.master.info.port", "XXX");
  conf.set("hbase.client.write.buffer", "52428800");
  conf.set("hbase.zookeeper.property.dataDir", "/data/home/zookeeper");
  conf.set("hbase.tmp.dir", "/data/home/hbase_tmp");
  conf.set("zookeeper.znode.parent", "/hbase");
  conf.set("hbase.hregion.max.filesize", "1073741824");
  conf.set("hbase.regionserver.handler.count", "20");
  conf.set("zookeeper.session.timeout", "180000");  

这个相当于hbase客户端程序的site.xml配置文件

读写注意事项:

读写接口中传的参数都是二进制数据流,调用的时候注意转换

  • Source Code
public static void readHbase(String table, String rowKey, String outfile, Configuration conf) throws IOException {

	byte[] ret = null;
		
	HTable htable = new HTable(conf, table);
		
	Get g = new Get(Bytes.toBytes(rowKey));
		
	System.out.println(g.toString());
		
	Result m = htable.get(g);
		
	ret = m.getValue("tarj_value".getBytes(), "Candy".getBytes());
		
        File out_file = new File(outfile);
                                                                 
        OutputStream out = null;

        try {
                 out = new FileOutputStream(out_file);
                 out.write(ret);
                 out.close();
            
        } catch (IOException e) {
        	
                 e.printStackTrace();
          
                 return;
        }   		
}
	
public static void writeHbase(String table, String rowKey, String infile, Configuration conf) throws IOException {
        File file = new File(infile);
        InputStream in = null;                                                                                                              
        long filelength = file.length();
        byte[] filecontent = null;
        try {
                 in = new FileInputStream(file);

                 filecontent = new byte[(int)filelength];
            
                 in.read(filecontent);

                 in.close();
        } catch (IOException e) {
                 e.printStackTrace();
             return;
        }   
 
	Put put_rows = new Put(rowKey.getBytes());
		
	put_rows.add("tarj_value".getBytes(), "Candy".getBytes(), filecontent);
		
	HTable htable = new HTable(conf, table);
		
	htable.put(put_rows);       
}

以上是关于habse入门级别的笔记(摘抄)的主要内容,如果未能解决你的问题,请参考以下文章

2016寒假读书笔记1-----20135204

Vue3入门级别笔记-适用于入门

AngularJS入门学习笔记一

摘抄笔记

Jenkins配置有用摘抄笔记

python数据分析入门学习笔记儿