91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

  • 大小: 20.94MB
    文件類型: .rar
    金幣: 1
    下載: 0 次
    發布日期: 2023-07-25
  • 語言: 其他
  • 標簽: spring??hbase??hadoop??

資源簡介

用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個文件信息

評論

共有 條評論