| 设为首页 加入收藏 |
当前位置: |
| TOP | ||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
|
HBaseAPI(二)
用法示例: HTable table = new HTable(conf, Bytes.toBytes(tablename)); ResultScanner scanner = table.getScanner(family); ---family指列族 ? Put 关系:org.apache.hadoop.hbase.client.Put 作用:用来对单个行执行添加操作
用法示例: ? HTable table = new HTable(conf,Bytes.toBytes(tablename)); Put p = new Put(brow);//为指定行创建一个Put操作 p.add(family,qualifier,value); table.put(p); ? Get 关系:org.apache.hadoop.hbase.client.Get 作用:用来获取单个行的相关信息
用法示例: ? HTable table = new HTable(conf, Bytes.toBytes(tablename)); Get g = new Get(Bytes.toBytes(row)); ? Result 关系:org.apache.hadoop.hbase.client.Result 作用:存储Get或者Scan操作后获取表的单行值。使用此类提供的方法可以直接获取值或者各种Map结构(key-value对)
? 实例: Htable table = new Htable(conf,Bytes.toBytes(tablename)); Get g = new Get(Bytes.toBytes(row)); Result rowResult = table.get(g); Bytes[] ret = rowResult.getValue(); ? ResultScanner 关系:Interface 作用:客户端获取值的接口
? 实例:
ResultScanner scanner = table.getScanner(Bytes.toBytes(family));
for (Result rowResult:sanner)
{
Bytes[] str =rowResult.getValue(family,column);
}
综合以上,一个例子如下:
package com.dream.hbase;
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.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 HBaseTest {
private HBaseAdminadmin = null;
// 定义配置对象HBaseConfiguration
privateHBaseConfiguration cfg = null;
private staticConfiguration conf = null;
static {
conf =HBaseConfiguration.create();
|
| 首页 上一页 1 2 3 下一页 尾页 2/3/3 | |
| 【大 中 小】【打印】 【繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部】 | |
|
分享到:
|
|
| 上一篇:数据库如何从SQL server转换到SQL.. | 下一篇:bat启动oracle本地服务 |
| 评论 |
|
|