Java RemoteHTable类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.hadoop.hbase.rest.client.RemoteHTable类的典型用法代码示例。如果您正苦于以下问题：Java RemoteHTable类的具体用法？Java RemoteHTable怎么用？Java RemoteHTable使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

RemoteHTable类属于org.apache.hadoop.hbase.rest.client包，在下文中一共展示了RemoteHTable类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: validate

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
/**
 * Prints the imported records
 */
public void validate() throws IOException {
	logger.info("Validating the records");
	RemoteHTable table = new RemoteHTable(hbaseConnection.getClient(), tableName);
	Scan scan = new Scan();
	ResultScanner scanner = table.getScanner(scan);
	Result result;
	int count = 5;
	logger.info("The first " + count + " will be displayed");
	DefaultDeserializer deserializer = new DefaultDeserializer();
	try {
		while ((result = scanner.next()) != null && count-- != 0) {
			printMap(result.getMap(), " ", deserializer);
		}
	} finally {
		scanner.close();
		table.close();
	}
}

开发者ID:OpenSoftwareSolutions，项目名称:PDFReporter-Studio，代码行数:22，代码来源:HBaseImporter.java

示例2: main

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
public static void main(String[] args) throws IOException {
  Configuration conf = HBaseConfiguration.create();

  HBaseHelper helper = HBaseHelper.getHelper(conf);
  helper.dropTable("testtable");
  helper.createTable("testtable", "colfam1");
  System.out.println("Adding rows to table...");
  helper.fillTable("testtable", 1, 100, 10, "colfam1");

  // vv RestExample
  Cluster cluster = new Cluster();
  cluster.add("localhost", 8080); // co RestExample-1-Cluster Set up a cluster list adding all known REST server hosts.

  Client client = new Client(cluster); // co RestExample-2-Client Create the client handling the HTTP communication.

  RemoteHTable table = new RemoteHTable(client, "testtable"); // co RestExample-3-Table Create a remote table instance, wrapping the REST access into a familiar interface.

  Get get = new Get(Bytes.toBytes("row-30")); // co RestExample-4-Get Perform a get operation as if it were a direct HBase connection.
  get.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-3"));
  Result result1 = table.get(get);

  System.out.println("Get result1: " + result1);

  Scan scan = new Scan();
  scan.setStartRow(Bytes.toBytes("row-10"));
  scan.setStopRow(Bytes.toBytes("row-15"));
  scan.addColumn(Bytes.toBytes("colfam1"), Bytes.toBytes("col-5"));
  ResultScanner scanner = table.getScanner(scan); // co RestExample-5-Scan Scan the table, again, the same approach as if using the native Java API.

  for (Result result2 : scanner) {
    System.out.println("Scan row[" + Bytes.toString(result2.getRow()) +
      "]: " + result2);
  }
  // ^^ RestExample
}

开发者ID:lhfei，项目名称:hbase-in-action，代码行数:36，代码来源:RestExample.java

示例3: main

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
public static void main(String[] args) {
    try {
		Configuration conf = HBaseConfiguration.create();

		HBaseHelper helper = HBaseHelper.getHelper(conf);
		helper.dropTable("test_table");
		helper.createTable("test_table", "music", "wallpaper", "others");
		System.out.println("Adding rows to table...");
		helper.fillTable("test_table", 1, 5, 10, "imtei");

		// vv RestExample
		Cluster cluster = new Cluster();
		cluster.add("centos10-82.letv.cn", 8080); //RestExample-1-Cluster Set up a cluster list adding all known REST server hosts.

		Client client = new Client(cluster); //RestExample-2-Client Create the client handling the HTTP communication.

		RemoteHTable table = new RemoteHTable(client, "test_table"); //RestExample-3-Table Create a remote table instance, wrapping the REST access into a familiar interface.

		Get get = new Get(Bytes.toBytes("row-30")); //RestExample-4-Get Perform a get operation as if it were a direct HBase connection.
		get.addColumn(Bytes.toBytes("music"), Bytes.toBytes("col-3"));
		Result result1 = table.get(get);

		log.info("Get result1: " ,result1);

		Scan scan = new Scan();
		scan.setStartRow(Bytes.toBytes("row-10"));
		scan.setStopRow(Bytes.toBytes("row-15"));
		scan.addColumn(Bytes.toBytes("music"), Bytes.toBytes("col-5"));
		ResultScanner scanner = table.getScanner(scan); //RestExample-5-Scan Scan the table, again, the same approach as if using the native Java API.

		for (Result result2 : scanner) {
			log.info("Scan row[{}", Bytes.toString(result2.getRow()), "]: {}", result2);
		}
	} catch (IOException e) {
		log.error(e.getMessage(), e);
	}

}

开发者ID:lhfei，项目名称:hadoop-in-action，代码行数:39，代码来源:RESTApp.java

示例4: setUpBeforeClass

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  LOG.info("Admin Connection=" + admin.getConnection() + ", " + 
    admin.getConnection().getZooKeeperWatcher());
  if (!admin.tableExists(TABLE)) {
    HTableDescriptor htd = new HTableDescriptor(TABLE);
    htd.addFamily(new HColumnDescriptor(COLUMN_1));
    htd.addFamily(new HColumnDescriptor(COLUMN_2));
    htd.addFamily(new HColumnDescriptor(COLUMN_3));
    admin.createTable(htd);
    HTable table = new HTable(TEST_UTIL.getConfiguration(), TABLE);
    LOG.info("Table connection=" + table.getConnection() + ", " +
      admin.getConnection().getZooKeeperWatcher());
    Put put = new Put(ROW_1);
    put.add(COLUMN_1, QUALIFIER_1, TS_2, VALUE_1);
    table.put(put);
    put = new Put(ROW_2);
    put.add(COLUMN_1, QUALIFIER_1, TS_1, VALUE_1);
    put.add(COLUMN_1, QUALIFIER_1, TS_2, VALUE_2);
    put.add(COLUMN_2, QUALIFIER_2, TS_2, VALUE_2);
    table.put(put);
    table.flushCommits();
  }
  remoteTable = new RemoteHTable(
    new Client(new Cluster().add("localhost", 
        REST_TEST_UTIL.getServletPort())),
      TEST_UTIL.getConfiguration(), TABLE);
}

开发者ID:zwqjsj0404，项目名称:HBase-Research，代码行数:32，代码来源:TestRemoteTable.java

示例5: setUpBeforeClass

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
@BeforeClass
public static void setUpBeforeClass() throws Exception {
  TEST_UTIL.startMiniCluster();
  REST_TEST_UTIL.startServletContainer(TEST_UTIL.getConfiguration());
  HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
  if (!admin.tableExists(TABLE)) {
    HTableDescriptor htd = new HTableDescriptor(TABLE);
    htd.addFamily(new HColumnDescriptor(COLUMN_1));
    htd.addFamily(new HColumnDescriptor(COLUMN_2));
    htd.addFamily(new HColumnDescriptor(COLUMN_3));
    admin.createTable(htd);
    HTable table = new HTable(TEST_UTIL.getConfiguration(), TABLE);
    Put put = new Put(ROW_1);
    put.add(COLUMN_1, QUALIFIER_1, TS_2, VALUE_1);
    table.put(put);
    put = new Put(ROW_2);
    put.add(COLUMN_1, QUALIFIER_1, TS_1, VALUE_1);
    put.add(COLUMN_1, QUALIFIER_1, TS_2, VALUE_2);
    put.add(COLUMN_2, QUALIFIER_2, TS_2, VALUE_2);
    table.put(put);
    table.flushCommits();
  }
  remoteTable = new RemoteHTable(
    new Client(new Cluster().add("localhost", 
        REST_TEST_UTIL.getServletPort())),
      TEST_UTIL.getConfiguration(), TABLE);
}

开发者ID:daidong，项目名称:DominoHBase，代码行数:28，代码来源:TestRemoteTable.java

示例6: getDataFromHbaseRest

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
public static void getDataFromHbaseRest() {
  ResultScanner scanner = null;// it needs to be initialized to null
  Cluster hbaseCluster = new Cluster();//Creating and cluster object
  hbaseCluster.add("172.28.182.45", 8080);//passing the IP and post 
  // Create Rest client instance and get the connection
  Client restClient = new Client(hbaseCluster);//pass the cluster object to the cliet
  table = new RemoteHTable(restClient, "mywebproject:myclickstream");// Makes a Remote Call 
  Get get = new Get(Bytes.toBytes("row02"));//Gets the row in question
  Result result1=null;// initilizing it to null
  try {
    result1 = table.get(get);// getting the table and the connection object
    byte[] valueWeb = result1.getValue(Bytes.toBytes("web"), Bytes.toBytes("col01"));
    byte[] valueWeb01 = result1.getValue(Bytes.toBytes("web"), Bytes.toBytes("col02"));
    /*
     * getting the  colum family: column qualifire values 
     * */
    byte[] valueWebData = result1.getValue(Bytes.toBytes("websitedata"), Bytes.toBytes("col01"));
    byte[] valueWebData01 = result1.getValue(Bytes.toBytes("websitedata"), Bytes.toBytes("col02"));
    /*
     * getting the  colum family: column qualifire values 
     * */
    String valueStr = Bytes.toString(valueWeb);
    String valueStr1 = Bytes.toString(valueWeb01);
    String valueWebdataStr = Bytes.toString(valueWebData);
    String valueWebdataStr1 = Bytes.toString(valueWebData01);
    
    System.out.println("GET: \n" + " web: " + valueStr + "\n web: " + valueStr1+"\n "+"Webdata: "+valueWebdataStr);
  } catch (IOException e1) {
    // TODO Auto-generated catch block
    e1.printStackTrace();
  }finally{
    /*make sure the resultset is set to null befoer exiting the program
     * In case its needed keep the object, but whenever the object is removed from the
     * rs, please null it. Its a good programming practive.
    */
    if(!result1.isEmpty());
    result1=null;
  }
  ResultScanner rsScanner = null;
  try {
    Scan s = new Scan();
    s.addColumn(Bytes.toBytes("web"), Bytes.toBytes("col01"));
    s.addColumn(Bytes.toBytes("web"), Bytes.toBytes("col02"));
    rsScanner = table.getScanner(s);

    for (Result rr = rsScanner.next(); rr != null; rr = rsScanner.next()) {
      System.out.println("Found row : " + rr);
    }
  } catch (Exception e) {
    e.printStackTrace();
  } finally {
    // Make sure you close your scanners when you are done!
    rsScanner.close();
  }
}

开发者ID:PacktPublishing，项目名称:HBase-High-Performance-Cookbook，代码行数:56，代码来源:package Col;.java

示例7: testSetup

import org.apache.hadoop.hbase.rest.client.RemoteHTable; //导入依赖的package包/类
void testSetup() throws IOException {
  this.table = new RemoteHTable(new Client(cluster), conf, tableName);
}

开发者ID:fengchen8086，项目名称:LCIndex-HBase-0.94.16，代码行数:4，代码来源:PerformanceEvaluation.java

注：本文中的org.apache.hadoop.hbase.rest.client.RemoteHTable类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java HikariPool类代码示例发布时间：2022-05-21

Java Connector类代码示例发布时间：2022-05-21

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：17934|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9557|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8121|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8501|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8406|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9295|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8370|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7798|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8351|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7355|2022-11-06

客服电话

电子邮件

Java RemoteHTable类代码示例

示例1: validate

示例2: main

示例3: main

示例4: setUpBeforeClass

示例5: setUpBeforeClass

示例6: getDataFromHbaseRest

示例7: testSetup

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

cakenggt/Library-Of-Pybel: Library of Ba

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053