Hadoop系列之学习笔记（一）

my11502207

HBase学习笔记（一）
1.HTable是HBase与用户接口交互的最核心的类.
  org.apache.hadoop.hbase.client.HTable
2.HTable-->HTablePool
3.Bytes Class的常用方法有
  1).byte[] toBytes(String s);
  2).byte[] toBytes(boolean b);
  3).byte[] toBytes(Long l);
  4).String toString(final byte [] b);
  5).static long toLong(byte[] bytes);
4.Put Class
  构造时一般需要指定具体的行Key
5.HTable-->put(Put put)-->Put Class-->RowKey
6.HBaseConfiguration继承于Configuration
  1).在初始化会根据系统配置找到hbase-default.xml与hbase-site.xml这二个文件并加载。
  2).在加载文件后，可以通过config.set("属性名","值")来修改相关配置。
7.查询行的各版本
  $hbase>scan 'test',{VERSIONS=>3}
  系统默认只记录最近三次的版本(timestamp)内容.
8.KeyValue Class 有三个重要参数getFamily(),getQualifier(),getTimestamp()
  描述了具体的数据模型。
9.HTable默认AutoFlush=true，可以修改为false，与之对应的方法是isAutoFlush(),flushCommits()
10.HTable中的put方法，可以直接put list内容，代码：
  List<Put> puts=new ArrayList<Put>();
  hTable.put(puts);
11.Get Class 示例代码：
  Get aGet = new Get(Bytes.toBytes("1"));
  aGet.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("列名"));
  Result result = hTable.get(aGet);
12.Result Class 查询结果
13.Result result.getMap();取得数据集内的信息，包括Family,Qualifier,Timestamp内的内容；
14.result.getNoVersionMap();不包含版本信息的，相对结构要简单一些。
部分示例代码：
构造内容：

HTable table = null;
Configuration conf = HBaseConfiguration.create();
conf.addResource(new Path("/usr/java/hbase-0.94.2/conf/hbase-site.xml"));
// conf.set("hbase.zookeeper.property.clientPort", "2222");
// conf.set("hbase.zookeeper.quorum","jcnep5422");
try {
table = new HTable(conf, "CusActive");
} catch (IOException e) {
e.printStackTrace();
}

测试函数：

public void test01() {
String newColumn = "AAAA";
Get myGet = new Get(Bytes.toBytes("1"));
// 指定Get函数要查看的列内容,有点象 SQL中的Select列内容定义
myGet.addColumn(Bytes.toBytes("cf"), Bytes.toBytes(newColumn));
myGet.addColumn(Bytes.toBytes("cf"), Bytes.toBytes("ID"));
Put put = new Put(Bytes.toBytes("1"));
Result result = null;
try {
put.add(Bytes.toBytes("cf"), Bytes.toBytes(newColumn), Bytes.toBytes("1981"));
table.put(put);
result = table.get(myGet);
if (!result.isEmpty()) {
KeyValue keyValue = result.getColumnLatest(Bytes.toBytes("cf"), Bytes.toBytes("ID"));
System.out.println("getFamily=" + Bytes.toString(keyValue.getFamily()));
System.out.println("getKey=" + Bytes.toString(keyValue.getKey()));
System.out.println("getRow=" + Bytes.toString(keyValue.getRow()));
System.out.println("getQualifier=" + Bytes.toString(keyValue.getQualifier()));
NavigableMap<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>> map = result.getMap();
Iterator<Entry<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>>> it = map.entrySet().iterator();
while (it.hasNext()) {
Entry<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>> ii = it.next();
System.out.println("列簇＝" + Bytes.toString(ii.getKey()));
NavigableMap<byte[], NavigableMap<Long, byte[]>> cfmap = ii.getValue();
Iterator<Entry<byte[], NavigableMap<Long, byte[]>>> cfit = cfmap.entrySet().iterator();
while (cfit.hasNext()) {
Entry<byte[], NavigableMap<Long, byte[]>> x1 = cfit.next();
System.out.println("  列＝" + Bytes.toString(x1.getKey()));
NavigableMap<Long, byte[]> qvmap = x1.getValue();
Iterator<Entry<Long, byte[]>> q1 = qvmap.entrySet().iterator();
while (q1.hasNext()) {
Entry<Long, byte[]> qv = q1.next();
System.out.print("    版本＝" + qv.getKey());
System.out.println("," + Bytes.toString(qv.getValue()));
}
}
}
List<KeyValue> kvlist= result.list();
for (KeyValue keyValue2 : kvlist) {
System.out.print(Bytes.toString( keyValue2.getFamily())+",");
System.out.print(Bytes.toString(keyValue2.getQualifier())+",");
System.out.print(keyValue2.getTimestamp()+",");
System.out.println(Bytes.toString(keyValue2.getValue()));
}
byte[] v1 = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes(newColumn));
byte[] v2 = result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("ID"));
System.out.println(newColumn + "=" + Bytes.toString(v1));
System.out.println(newColumn + "=" + Bytes.toString(v2));
} else {
System.out.println("对象为空");
}
} catch (IOException e) {
e.printStackTrace();
}
}