spring操作hbase

用spring-hadoop-data操作hbase的示例代码。

package cn.fulong.hbase;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathxmlApplicationContext;
import org.springframework.data.hadoop.hbase.HbaseTemplate;
import org.springframework.data.hadoop.hbase.RowMapper;
import org.springframework.data.hadoop.hbase.TableCallback;

import cn.fulong.view.HbaseModel;
public class HbaseTest {
 	//ApplicationContext context = new ClassPathxmlApplicationContext（new String[] { “application_hbase.xml“ }）;  
 	ApplicationContext context = new ClassPathxmlApplicationContext（new String[] { “spring_hbase.xml“ }）;  

	BeanFactory factory = （BeanFactory） context; 
	HbaseTemplate htemplate = （HbaseTemplate） factory.getBean（“htemplate“）;
	Map hMap = new HashMapseModel>>（）;
	public String key;
	public String familyName ;
	public String qualifier;
	public String value;
		
	public String getValue（） {
		return value;
	}
	public void setValue（String value） {
		this.value = value;
	}
	public String getFamilyName（） {
		return familyName;
	}
	public void setFamilyName（String familyName） {
		this.familyName = familyName;
	}
	public String getQualifier（） {
		return qualifier;
	}
	public void setQualifier（String qualifier） {
		this.qualifier = qualifier;
	}
	public String getKey（） {
		return key;
	}
	public void setKey（String key） {
		this.key = key;
	}
	
		 
		
	public static void main（String[] args） {
		//PrefixFilter
		HbaseTest h = new HbaseTest（）;
 
		for（int i=0;i<=10000;i++）{
			h.setKey（“linlin“+i）;
			h.setFamilyName（“info“）; 
			h.setQualifier（“service“）;
			h.setValue（i+“技术创新和质量服务“）;
			h.execute（“linlintest“ null）;
		}
	
	 Listject>>  mapList1 = h.find（“linlintest“nullnull）;
	 	System.out.println（“2“）;
	}
	/**
	 * 写数据
	 * @param tableName
	 * @param action
	 * @return
	 */
	public Boolean execute（String tableName TableCallback action） {  
		return htemplate.execute（tableName new TableCallback（） {
            public Boolean doInTable（HTableInterface table） throws Throwable {
                boolean flag = false;
                try{
                	byte[] rowkey = key.getBytes（）;
                	Put put = new Put（rowkey）;
                	put.add（Bytes.toBytes（familyName）Bytes.toBytes（qualifier） Bytes.toBytes（value））;
                	table.put（put）;
                 flag = true;
                }catch（Exception e）{
                    e.printStackTrace（）;
                }
                return flag;
            }
        }

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件        588  2014-11-28 10:47  springDataHadoop\.classpath

     文件       1049  2014-11-28 10:47  springDataHadoop\.project

     文件        503  2014-11-28 10:47  springDataHadoop\.settings\.jsdtscope

     文件         57  2014-12-31 09:10  springDataHadoop\.settings\org.eclipse.core.resources.prefs

     文件        364  2014-11-28 10:47  springDataHadoop\.settings\org.eclipse.jdt.core.prefs

     文件        500  2014-11-28 10:47  springDataHadoop\.settings\org.eclipse.wst.common.component

     文件        305  2014-11-28 10:47  springDataHadoop\.settings\org.eclipse.wst.common.project.facet.core.xml

     文件         49  2014-11-28 10:47  springDataHadoop\.settings\org.eclipse.wst.jsdt.ui.superType.container

     文件          6  2014-11-28 10:47  springDataHadoop\.settings\org.eclipse.wst.jsdt.ui.superType.name

     文件       1290  2015-03-12 17:42  springDataHadoop\build\classes\application_hbase.xml

     文件       2044  2015-04-10 09:53  springDataHadoop\build\classes\cn\fulong\hbase\HbaseTest$1.class

     文件       2826  2015-04-10 09:53  springDataHadoop\build\classes\cn\fulong\hbase\HbaseTest$2.class

     文件       2042  2015-04-10 09:53  springDataHadoop\build\classes\cn\fulong\hbase\HbaseTest$3.class

     文件       3241  2015-04-10 09:53  springDataHadoop\build\classes\cn\fulong\hbase\HbaseTest$4.class

     文件       5271  2015-04-10 09:53  springDataHadoop\build\classes\cn\fulong\hbase\HbaseTest.class

     文件       5595  2015-03-27 12:34  springDataHadoop\build\classes\cn\fulong\hbase\HdfsDAO.class

     文件        935  2015-03-27 12:34  springDataHadoop\build\classes\cn\fulong\view\HbaseModel.class

     文件       1173  2015-04-10 09:25  springDataHadoop\build\classes\hbase-site.xml

     文件        146  2015-03-12 11:34  springDataHadoop\build\classes\hbase.properties

     文件       1001  2015-04-10 09:26  springDataHadoop\build\classes\spring_hbase.xml

     文件       1290  2015-03-12 17:42  springDataHadoop\src\application_hbase.xml

     文件       6905  2015-04-10 09:53  springDataHadoop\src\cn\fulong\hbase\HbaseTest.java

     文件       4388  2015-01-04 10:37  springDataHadoop\src\cn\fulong\hbase\HdfsDAO.java

     文件        576  2014-11-25 10:37  springDataHadoop\src\cn\fulong\view\HbaseModel.java

     文件       1173  2015-04-10 09:25  springDataHadoop\src\hbase-site.xml

     文件        146  2015-03-12 11:34  springDataHadoop\src\hbase.properties

     文件       1001  2015-04-10 09:26  springDataHadoop\src\spring_hbase.xml

     文件         39  2014-11-28 10:47  springDataHadoop\WebContent\meta-INF\MANIFEST.MF

     文件     259600  2014-11-26 13:13  springDataHadoop\WebContent\WEB-INF\lib\commons-codec-1.7.jar

     文件     575389  2014-11-26 13:03  springDataHadoop\WebContent\WEB-INF\lib\commons-collections-3.2.1.jar

............此处省略60个文件信息