欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

hbase訪問方式之java api

 更新時(shí)間:2017年09月29日 14:05:34   作者:動(dòng)力節(jié)點(diǎn)  
這篇文章主要介紹了hbase訪問方式之java api,需要的朋友可以參考下

Hbase的訪問方式

1、Native Java API:最常規(guī)和高效的訪問方式;

2、HBase Shell:HBase的命令行工具,最簡單的接口,適合HBase管理使用;

3、Thrift Gateway:利用Thrift序列化技術(shù),支持C++,PHP,Python等多種語言,適合其他異構(gòu)系統(tǒng)在線訪問HBase表數(shù)據(jù);

4、REST Gateway:支持REST 風(fēng)格的Http API訪問HBase, 解除了語言限制;

5、MapReduce:直接使用MapReduce作業(yè)處理Hbase數(shù)據(jù);

6、使用Pig/hive處理Hbase數(shù)據(jù)。

常用Java API的用法:

1、加載配置

Configuration config = HBaseConfiguration.create();  
//可以自定義配置,也可以從自定義配置文件中讀取 
/*config.set("hbase.zookeeper.property.clientPort", "4181"); 
config.set("hbase.zookeeper.quorum", "hadoop.datanode5.com,hadoop.datanode2.com,hadoop.datanode3.com"); 
config.set("hbase.master", "hadoop.datanode3.com\\:600000");*/ 

2、表的創(chuàng)建、表信息修改、表刪除

HBaseAdmin admin = new HBaseAdmin(config); 
//創(chuàng)建表 
HTableDescriptor htd = new HTableDescriptor(tableName); 
htd.addFamily(new HColumnDescriptor("cf1")); 
htd.addFamily(new HColumnDescriptor("cf2")); 
admin.createTable(htd); 
//修改表信息 
admin.disableTable(tableName); 
// modifying existing ColumnFamily 
admin.modifyColumn(tableName, new HColumnDescriptor("cf1"));  
admin.enableTable(tableName);  
//刪除表 
admin.disableTable(Bytes.toBytes(tableName)); 
admin.deleteTable(Bytes.toBytes(tableName)); 

3、添加記錄

/** 在多次使用時(shí),建議用HTablePool 
 HTable table = new HTable(config, tableName); 
 => 
 HTablePool pool = new HTablePool(config, 1000); 
 HTableInterface table = pool.getTable(tableName);*/ 
HTable table = new HTable(config, tableName); 
 
/** 
 * 在插入操作時(shí),默認(rèn)不適用任何緩存 
 * 可自定義使用緩存,以及緩存大小 
 * 每個(gè)任務(wù)最后需要手工調(diào)用 flushCommits(); 
 */ 
/*table.setAutoFlush(false); 
table.setWriteBufferSize(1024);*/ 
 
Put put1 = new Put(Bytes.toBytes(rowKey)); 
if (ts == 0) { 
  put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), Bytes.toBytes(value)); 
} else { 
    //自定義版本時(shí),從自定義的版本號,類型為long 
  put1.add(Bytes.toBytes(family), Bytes.toBytes(qualifier), ts,Bytes.toBytes(value)); 
} 
table.put(put1); 
//table.flushCommits(); 

4、查詢,根據(jù)Rowkey查詢

Get get1 = new Get(Bytes.toBytes(rowKey)); 
Result result = table.get(get1); 
System.out.println("get result:" + Bytes.toString(result.getValue(Bytes.toBytes(family), Bytes.toBytes(qualifier)))); 
Result[] result = table.get(List<Get>);//查詢指定Rowkey的多條記錄 

5、查詢,指定條件和rowkey區(qū)間查詢

Scan scan = new Scan(); 
//默認(rèn)緩存大小為1,設(shè)置成一個(gè)合理的值,可以減少scan過程中next()的時(shí)間開銷,代價(jià)是客戶端的內(nèi)存 
scan.setCaching(500); 
scan.setCacheBlocks(false); 
//根據(jù)startRowKey、endRowKey查詢 
//Scan scan = new Scan(Bytes.toBytes("startRowKey"), Bytes.toBytes("endRowKey")); 
//rowKey之外的過濾條件,在List中可以add; 
/**List<Filter> filters = new ArrayList<Filter>(); 
Filter filter = new SingleColumnValueFilter("familyName".getBytes(), 
    "qualifierName".getBytes(), 
    CompareOp.EQUAL, 
    Bytes.toBytes("value")); 
filters.add(filter); 
scan.setFilter(new FilterList(filters));*/ 
ResultScanner scanner = table.getScanner(scan); 
System.out.println("scan result list:"); 
for (Result result : scanner) { 
  System.out.println(Bytes.toString(result.getRow())); 
  System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data1")))); 
  System.out.println(Bytes.toString(result.getValue(Bytes.toBytes("data"), Bytes.toBytes("data2")))); 
} 
scanner.close(); 

總結(jié)

以上所述是小編給大家介紹的hbase訪問方式之java api,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時(shí)回復(fù)大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!

相關(guān)文章

  • Java編程使用箱式布局管理器示例【基于swing組件】

    Java編程使用箱式布局管理器示例【基于swing組件】

    這篇文章主要介紹了Java編程使用箱式布局管理器,結(jié)合實(shí)例形式分析了基于swing組件的箱式布局管理器定義與使用技巧,需要的朋友可以參考下
    2018-01-01
  • 使用feign傳遞參數(shù)類型為MultipartFile的問題

    使用feign傳遞參數(shù)類型為MultipartFile的問題

    這篇文章主要介紹了使用feign傳遞參數(shù)類型為MultipartFile的問題,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-03-03
  • spring框架下websocket的搭建

    spring框架下websocket的搭建

    本篇文章主要介紹了spring框架下websocket的搭建,非常具有實(shí)用價(jià)值,需要的朋友可以參考下。
    2017-03-03
  • MybatisPlus處理四種表與實(shí)體的映射及id自增策略分析

    MybatisPlus處理四種表與實(shí)體的映射及id自增策略分析

    在最近的工作中,碰到一個(gè)比較復(fù)雜的返回結(jié)果,發(fā)現(xiàn)簡單映射已經(jīng)解決不了這個(gè)問題了,只好去求助百度,學(xué)習(xí)mybatis表與實(shí)體的映射應(yīng)該怎么寫,將學(xué)習(xí)筆記結(jié)合工作碰到的問題寫下本文,供自身查漏補(bǔ)缺,同時(shí)已被不時(shí)之需
    2022-10-10
  • 通過JDK源碼角度分析Long類詳解

    通過JDK源碼角度分析Long類詳解

    這篇文章主要給大家介紹了關(guān)于通過JDK源碼角度分析Long類的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對大家學(xué)習(xí)或者使用long類具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。
    2017-11-11
  • Java并發(fā)編程之synchronized底層實(shí)現(xiàn)原理分析

    Java并發(fā)編程之synchronized底層實(shí)現(xiàn)原理分析

    這篇文章主要介紹了Java并發(fā)編程之synchronized底層實(shí)現(xiàn)原理,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-02-02
  • java正則表達(dá)式應(yīng)用的實(shí)例代碼

    java正則表達(dá)式應(yīng)用的實(shí)例代碼

    java正則的實(shí)例應(yīng)用分析,大家從下面的代碼中,就能知道java正則的應(yīng)用與寫法
    2008-10-10
  • 你肯定能看懂的Java IO相關(guān)知識總結(jié)

    你肯定能看懂的Java IO相關(guān)知識總結(jié)

    群里有大佬說想讓我寫一篇NIO,一直也沒寫,但是和同事聊天也說對Java的IO不是很清晰,因此今天就寫下Java的io,先打個(gè)基礎(chǔ),下次寫NIO,需要的朋友可以參考下
    2021-05-05
  • RabbitMQ?Stream插件使用案例代碼

    RabbitMQ?Stream插件使用案例代碼

    這篇文章主要介紹了RabbitMQ?Stream插件使用案例代碼,2.4版為RabbitMQ流插件引入了對RabbitMQStream插件Java客戶端的初始支持,需要的朋友可以參考下
    2024-04-04
  • Springboot2.0自適應(yīng)效果錯(cuò)誤響應(yīng)過程解析

    Springboot2.0自適應(yīng)效果錯(cuò)誤響應(yīng)過程解析

    這篇文章主要介紹了Springboot2.0自適應(yīng)效果錯(cuò)誤響應(yīng)過程解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-11-11

最新評論