CellUtil：createCell 方法中的键类型

Question

我正在使用打包在 org.apache.hadoop.hbase 中的 CellUtil class 创建一个 单元格 对象。函数头如下所示：

public static Cell createCell(byte[] row, byte[] family, byte[] qualifier, long timestamp, byte type, byte[] value)

第五个是什么意思。 argument bytetype代表什么？我查看了 KeyValueType class，它引用了一个名为 Type 的枚举，其定义如下：

public static enum Type {
Minimum((byte)0),
Put((byte)4),

Delete((byte)8),
DeleteFamilyVersion((byte)10),
DeleteColumn((byte)12),
DeleteFamily((byte)14),

// Maximum is used when searching; you look from maximum on down.
Maximum((byte)255);

private final byte code;

Type(final byte c) {
  this.code = c;
}

public byte getCode() {
  return this.code;
}

我的问题是，minimum、put 等类型与我要创建的单元格类型有什么关系？

Answer 1

沙林，请参考69.7.6. KeyValue

在某些情况下您将使用这些枚举。例如，我正在编写如下所示的协处理器，然后我将使用 KeyValue.Type.Put.getCode() 类似地，其他枚举也可以这样使用。请参阅下面的协处理器使用示例...

package getObserver;

import java.io.IOException;
import java.util.List;
import java.util.NavigableSet;

import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.coprocessor.BaseRegionObserver;
import org.apache.hadoop.hbase.coprocessor.ObserverContext;
import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment;

public class Observer extends BaseRegionObserver{

    private boolean isOewc;

    @Override
    public void preGetOp(ObserverContext<RegionCoprocessorEnvironment> arg0,
            Get arg1, List<Cell> arg2) throws IOException {
        NavigableSet<byte[]> qset = arg1.getFamilyMap().get("colfam1".getBytes());
        if(qset==null){//do nothing

        }else{

            String message = "qset.size() = "+String.valueOf(qset.size());
            String m = "isOewc = "+String.valueOf(isOewc);
            this.isOewc = true;
            Cell cell = CellUtil.createCell(
                    "preGet Row".getBytes(), 
                    m.getBytes(), 
                    message.getBytes(), 
                    System.currentTimeMillis(), 
                    KeyValue.Type.Put.getCode(), 
                    "preGet Value".getBytes());
            arg2.add(cell);
        }
    }

    @Override
    public void postGetOp(ObserverContext<RegionCoprocessorEnvironment> arg0,
            Get arg1, List<Cell> arg2) throws IOException {
        String m = "isOewc = "+String.valueOf(isOewc);
        Cell cell = CellUtil.createCell(
                "postGet Row".getBytes(), 
                m.getBytes(), 
                "postGet Qualifier".getBytes(), 
                System.currentTimeMillis(), 
                KeyValue.Type.Put.getCode(), 
                "postGet Value".getBytes());
        arg2.add(cell);
    }
}

Similarly other below EnumTypes can be used if you don't know which operation you are going to perform on co-processor event..

programcreek examples 清楚地解释了 Put,Delete(为突变准备键值对)maximum,minimum(用于范围检查)的用法。上述示例中的协处理器也使用了 Put。

CellUtil：createCell 方法中的键类型

CellUtil: Key type in createCell method

java

hadoop

hbase