为了账号安全,请及时绑定邮箱和手机立即绑定

请教一下该如何使用eclipse maven构建hbase开发环境?

/ 猿问

请教一下该如何使用eclipse maven构建hbase开发环境?

慕粉4167745 2019-10-20 15:09:26

如何使用eclipse maven构建hbase开发环境


查看完整描述

3 回答

?
守着星空守着你

环境需求
Eclipse版本:eclipse-jee-mars-1
操作系统:Ubuntu15.04
Hadoop:1.2.1
HBase:0.94.13
搭建过程
运行Eclipse,创建一个新的Java工程“hbaseTest”,右键项目根目录,选择 “Properties”->“Java Build Path”->“Library”->“Add External JARs”,将HBase解压后根目录下的hbase-0.94.13-security.jar、hbase-0.94.13-security-tests.jar和lib子目录下所有jar 包添加到本工程的Classpath下。
工程根目录下创建文件夹conf,将hbase解压后根目录下的conf文件夹内的hbase-site.xml拷贝过来。

查看完整回答
反对 回复 2019-10-26
?
摇曳的蔷薇

 步骤如下:
  1:从HBase集群中复制一份Hbase部署文件,放置在开发端某一目录下(如在/app/hadoop/hbase096目录下)。
  2:在eclipse里新建一个java项目HBase,然后选择项目属性,在Libraries->Add External JARs...,然后选择/app/hadoop/hbase096/lib下相关的JAR包,如果只是测试用的话,就简单一点,将所有的JAR选上。

  3:在项目HBase下增加一个文件夹conf,将Hbase集群的配置文件hbase-site.xml复制到该目录,然后选择项目属性在Libraries->Add Class Folder,将刚刚增加的conf目录选上。

  4:在HBase项目中增加一个chapter12的package,然后增加一个HBaseTestCase的class,然后将《Hadoop实战第2版》12章的代码复制进去,做适当的修改,代码如下:

  package chapter12;

  import java.io.IOException;

  import org.apache.hadoop.conf.Configuration;

  import org.apache.hadoop.hbase.HBaseConfiguration;

  import org.apache.hadoop.hbase.HColumnDescriptor;

  import org.apache.hadoop.hbase.HTableDescriptor;

  import org.apache.hadoop.hbase.client.Get;

  import org.apache.hadoop.hbase.client.HBaseAdmin;

  import org.apache.hadoop.hbase.client.HTable;

  import org.apache.hadoop.hbase.client.Put;

  import org.apache.hadoop.hbase.client.Result;

  import org.apache.hadoop.hbase.client.ResultScanner;

  import org.apache.hadoop.hbase.client.Scan;

  import org.apache.hadoop.hbase.util.Bytes;

  public class HBaseTestCase {

  //声明静态配置 HBaseConfiguration

  static Configuration cfg=HBaseConfiguration.create();

  //创建一张表,通过HBaseAdmin HTableDescriptor来创建

  public static void creat(String tablename,String columnFamily) throws Exception {

  HBaseAdmin admin = new HBaseAdmin(cfg);

  if (admin.tableExists(tablename)) {

  System.out.println("table Exists!");

  System.exit(0);

  }

  else{

  HTableDescriptor tableDesc = new HTableDescriptor(tablename);

  tableDesc.addFamily(new HColumnDescriptor(columnFamily));

  admin.createTable(tableDesc);

  System.out.println("create table success!");

  }

  }

  

  //添加一条数据,通过HTable Put为已经存在的表来添加数据

  public static void put(String tablename,String row, String columnFamily,String column,String data) throws Exception {

  HTable table = new HTable(cfg, tablename);

  Put p1=new Put(Bytes.toBytes(row));

  p1.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(data));

  table.put(p1);

  System.out.println("put '"+row+"','"+columnFamily+":"+column+"','"+data+"'");

  }

  

  public static void get(String tablename,String row) throws IOException{

  HTable table=new HTable(cfg,tablename);

  Get g=new Get(Bytes.toBytes(row));

  Result result=table.get(g);

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

  }

  //显示所有数据,通过HTable Scan来获取已有表的信息

  public static void scan(String tablename) throws Exception{

  HTable table = new HTable(cfg, tablename);

  Scan s = new Scan();

  ResultScanner rs = table.getScanner(s);

  for(Result r:rs){

  System.out.println("Scan: "+r);

  }

  }

  

  public static boolean delete(String tablename) throws IOException{

  

  HBaseAdmin admin=new HBaseAdmin(cfg);

  if(admin.tableExists(tablename)){

  try

  {

  admin.disableTable(tablename);

  admin.deleteTable(tablename);

  }catch(Exception ex){

  ex.printStackTrace();

  return false;

  }

  

  }

  return true;

  }

  

  public static void main (String [] agrs) {

  String tablename="hbase_tb";

  String columnFamily="cf";

  

  try {

  HBaseTestCase.creat(tablename, columnFamily);

  HBaseTestCase.put(tablename, "row1", columnFamily, "cl1", "data");

  HBaseTestCase.get(tablename, "row1");

  HBaseTestCase.scan(tablename);

  /* if(true==HBaseTestCase.delete(tablename))

  System.out.println("Delete table:"+tablename+"success!");

  */

  }

  catch (Exception e) {

  e.printStackTrace();

  }

  }

  }
  5:设置运行配置,然后运行。运行前将Hbase集群先启动。

  6:检验,使用hbase shell查看hbase,发现已经建立表hbase_tb。



查看完整回答
反对 回复 2019-10-26
?
RISEBY

方法:将下载的hadoop-eclipse-plugin-2.2.0.jar放到eclipse根目录下的plugins目录下,然后开启eclipse。配置hadoop location。有些步骤不是开发必须,但是配置了后可在resource视图下通过DFS location查看到hadoop的hdfs内容
修改开发机上的hosts。如添加:
192.168.17.129 master
192.168.17.128 slave1
192.168.17.131 slave2
开发过程:
1、连接到hbase。
建表。这个示例代码是建立三个column family分别为column1、colunm2和column3
入数据。在上面建好的表实现将文件以byte[]形式存储到hdfs中。ByteUtil.file2Bytes是我自定义的方法,就是通过流方式读取将文件变成byte[]的过程。
删除表。
全表查询
根据rowkey数据进行行数据查询
根据某个column下的qulify进行查询
组合条件查询

查看完整回答
反对 回复 2019-10-26

添加回答

回复

举报

0/150
提交
取消
意见反馈 帮助中心 APP下载
官方微信