资源简介

节制2013年12月23日最新的hadoop和hbase兼容版本搭建 hadoop-2.2.0 hbase-0.96.1.1 java Hbase java DBHelper CRUD等通用方法 花了两天时间整理的,含有lib包 & 源码

资源截图

代码片段和文件信息

package com.demo;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
 
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.KeyValue;
import org.apache.hadoop.hbase.MasterNotRunningException;
import org.apache.hadoop.hbase.ZooKeeperConnectionException;
import org.apache.hadoop.hbase.client.Delete;
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.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.util.Bytes;
 
public class HbaseTest {
    
    private static Configuration conf = null;
     
    /**
     * 初始化配置
     */
    static {
        Configuration Hbase_CONFIG = new Configuration();
        //与hbase/conf/hbase-site.xml中hbase.zookeeper.quorum配置的值相同 
        Hbase_CONFIG.set(“hbase.zookeeper.quorum“ “172.16.12.99“);
        //与hbase/conf/hbase-site.xml中hbase.zookeeper.property.clientPort配置的值相同
        Hbase_CONFIG.set(“hbase.zookeeper.property.clientPort“ “2181“);
        conf = HbaseConfiguration.create(Hbase_CONFIG);
    }
    
    /**
     * 创建一张表
     */
    public static void creatTable(String tableName String[] familys) throws Exception {
        HbaseAdmin admin = new HbaseAdmin(conf);
        if (admin.tableExists(tableName)) {
            System.out.println(“table already exists!“);
        } else {
            HTableDescriptor tableDesc = new HTableDescriptor(tableName);
            for(int i=0; i                tableDesc.addFamily(new HColumnDescriptor(familys[i]));
            }
            admin.createTable(tableDesc);
            System.out.println(“create table “ + tableName + “ ok.“);
        } 
    }
    
    /**
     * 删除表
     */
    public static void deleteTable(String tableName) throws Exception {
       try {
           HbaseAdmin admin = new HbaseAdmin(conf);
           admin.disableTable(tableName);
           admin.deleteTable(tableName);
           System.out.println(“delete table “ + tableName + “ ok.“);
       } catch (MasterNotRunningException e) {
           e.printStackTrace();
       } catch (ZooKeeperConnectionException e) {
           e.printStackTrace();
       }
    }
     
    /**
     * 插入一行记录
     */
    public static void addRecord (String tableName String rowKey String family String qualifier String value)
            throws Exception{
        try {
            HTable table = new HTable(conf tableName);
            Put put = new Put(Bytes.toBytes(rowKey));
            put.add(Bytes.toBytes(family)Bytes.toBytes(qualifier)Bytes.toBytes(value));

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----
     目录           0  2013-12-23 17:42  testHbase2.2\
     文件        1705  2013-12-23 17:40  testHbase2.2\.classpath
     文件         388  2013-12-23 13:27  testHbase2.2\.project
     目录           0  2013-12-23 17:42  testHbase2.2\.settings\
     文件         629  2013-12-23 13:27  testHbase2.2\.settings\org.eclipse.jdt.core.prefs
     目录           0  2013-12-23 17:42  testHbase2.2\bin\
     目录           0  2013-12-23 17:42  testHbase2.2\bin\com\
     目录           0  2013-12-23 17:42  testHbase2.2\bin\com\demo\
     文件        7082  2013-12-23 17:40  testHbase2.2\bin\com\demo\HbaseTest.class
     文件        4997  2013-12-23 17:40  testHbase2.2\bin\com\demo\HbaseTestCase.class
     文件        9028  2013-12-23 17:40  testHbase2.2\bin\com\demo\JinTaoTest.class
     文件         302  2013-12-23 16:56  testHbase2.2\bin\readme.txt
     目录           0  2013-12-23 17:42  testHbase2.2\lib\
     文件      259600  2013-12-23 17:40  testHbase2.2\lib\commons-codec-1.7.jar
     文件      298829  2013-12-23 17:40  testHbase2.2\lib\commons-configuration-1.6.jar
     文件      284220  2013-12-23 17:40  testHbase2.2\lib\commons-lang-2.6.jar
     文件       60686  2013-12-23 17:40  testHbase2.2\lib\commons-logging-1.1.1.jar
     文件     1795932  2013-12-23 17:40  testHbase2.2\lib\guava-12.0.1.jar
     文件       49750  2013-12-23 17:40  testHbase2.2\lib\hadoop-auth-2.2.0.jar
     文件     2735584  2013-12-23 17:40  testHbase2.2\lib\hadoop-common-2.2.0.jar
     文件      825224  2013-12-23 17:40  testHbase2.2\lib\hbase-client-0.96.1-hadoop2.jar
     文件      367310  2013-12-23 17:40  testHbase2.2\lib\hbase-common-0.96.1-hadoop2.jar
     文件       72869  2013-12-23 17:40  testHbase2.2\lib\hbase-hadoop2-compat-0.96.1-hadoop2.jar
     文件     3135071  2013-12-23 17:40  testHbase2.2\lib\hbase-protocol-0.96.1-hadoop2.jar
     文件       31020  2013-12-23 17:40  testHbase2.2\lib\htrace-core-2.01.jar
     文件      227517  2013-12-23 17:40  testHbase2.2\lib\jackson-core-asl-1.8.8.jar
     文件      669065  2013-12-23 17:40  testHbase2.2\lib\jackson-mapper-asl-1.8.8.jar
     文件      489884  2013-12-23 17:40  testHbase2.2\lib\log4j-1.2.17.jar
     文件     1206119  2013-12-23 17:40  testHbase2.2\lib\netty-3.6.6.Final.jar
     文件       29555  2013-12-23 17:40  testHbase2.2\lib\paranamer-2.3.jar
     文件      533455  2013-12-23 17:40  testHbase2.2\lib\protobuf-java-2.5.0.jar
............此处省略10个文件信息

评论

共有 条评论