ubantu操作hbase

到firefox中按照网站找以下文件进行下载

新建一个窗口启动节点

下载完成则回到下载目录

如果下载慢也可以将文件放在share中，然后拷贝到当前目录

进入到root

然后回到hadoop

解压到/usr/local

进入到local，将hbase改名

修改权限

配置环境变量

执行

回到hbase配置conf文件

打开另一个窗口找到这个路径

然后复制到这个下面

最底下注释掉这个

配置site

启动hbase

通过shell进入hbase查看版本号，可以通过exit退出

再通过version

再进入Hbase shell启动管理器。然后通过list查看

如果有student这个表可以先删除了

打开eclipse，然后新建一个项目

添加jar包

Lib包下除了文件夹其他都添加进去

再添加这个jar包，即可finish

在该项目下创建一个新的类

然后编写以下代码进行测试

package hbaseTestfile;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;import java.io.IOException;public class hBaseTest {public static Configuration configuration;public static Connection connection;public static Admin admin;public static void main(String[] args) throws IOException{init();createTable("student", new String[]{"score"});insertData("student", "zhangsan", "score", "English", "69");insertData("student", "zhangsan", "score", "Math", "86");insertData("student", "zhangsan", "score", "Computer", "77");getData("student", "zhangsan", "score", "English");close();}public static void init(){configuration = HBaseConfiguration.create();configuration.set("Hbase.rootdir","hdfs://localhost:9000/hbase");try {connection = ConnectionFactory.createConnection(configuration);admin = connection.getAdmin();}catch (IOException e) {e.printStackTrace();}}public static void close(){try {if(admin != null) {admin.close();}if(null != connection){connection.close();}}catch (IOException e) {e.printStackTrace();}}public static void createTable(String myTableName, String[] colFamily) throws IOException{TableName tableName = TableName.valueOf(myTableName);if(admin.tableExists(tableName)) {System.out.println("table exists");}else {TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);for(String str: colFamily) {ColumnFamilyDescriptor family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();tableDescriptor.setColumnFamily(family);}admin.createTable(tableDescriptor.build());}}public static void insertData(String tableName, String rowKey, String colFamily, String col, String val) throws IOException {Table table = connection.getTable(TableName.valueOf(tableName));Put put = new Put(rowKey.getBytes());put.addColumn(colFamily.getBytes(), col.getBytes(), val.getBytes());table.put(put);		table.close();	}public static void getData(String tableName, String rowKey, String colFamily, String col) throws IOException{Table table = connection.getTable(TableName.valueOf(tableName));Get get = new Get(rowKey.getBytes());get.addColumn(colFamily.getBytes(), col.getBytes());Result result = table.get(get);System.out.println(new String(result.getValue(colFamily.getBytes(), col==null?null:col.getBytes())));table.close();	}}

启动项目后

可以看到正确输出69