如果我们指定值，Get HBase API是否检索columnsfamily和列名？

Question

我有一个表，假设它的名字是“SampleTab”，它有一个名为“ColumnFam1”的ColumnFam1的column Family和一个名为“1”的Coll1Value的值。

我编写了这段代码，并试图通过传递我获得输出的列值来获得输出

/04/04 06:50:08信息zookeeper.zookeeper:Client environment:java.io.tmpdir=/tmp 15/04/04 06:50:08信息zookeeper.zookeeper:Client environment:java.compiler=15/04/04 06:50:08信息zookeeper.zookeeper:Client environment:java.compiler=15/04/04 06:50:08信息zookeeper.zookeeper:Client environment:os.name=linux 15/04/04 keeper.zookeeper:客户端环境:user.name=training 15/04/04 06:50:08信息zookeeper.zookeeper:Client环境:user.home=/home/training 15/04/04 06:50:08信息zookeeper.zookeeper:Client环境:user.home=/home/training 15/04/04 06:50:08信息zookeeper.zookeeper:Client环境:user.dir=/home/training 15/04/04 06:50:08信息/04 06:50:09信息zookeeper.clientcnxn：与本地主机建立套接字连接/127.0.0.1:2181，初始化会话15/04/04 06:50:09信息zookeeper.clientcnxn:在服务器本地主机上完成会话建立/127.0.0.1:2181，sessionid=0x14C84AE2FB30005，协商超时=40000 15/04/04 06:50:11信息zookeeper.zookeeper:初始化客户端连接，connectstring=localhost:2181 sessiontimeout=180000 watcher=hconnection 15/04/04 06:50:11信息zookeeper.clientcnxn:打开到服务器本地主机/127.0.0.1:2181的套接字04/04 06:50:11 INFO zookeeper.clientcnxn:建立到localhost/127.0.0.1:2181的套接字连接，启动会话15/04/04 06:50:12 INFO zookeeper.clientcnxn:服务器localhost/127.0.0.1:2181上完成会话建立，sessionid=0x14C84AE2FB30006，协商超时=40000 get:OUTPUT keyvalues=none

下面是我要获取的部分代码：

HTable table = new HTable(config, tablename);
        byte [] row1 = Bytes.toBytes("KeyIn");
        Put p1 = new Put(row1);
        byte [] databytes = Bytes.toBytes("ColumnFam1");
        p1.add(databytes, Bytes.toBytes("1"), Bytes.toBytes("col1value"));
        table.put(p1);
        Get g = new Get(Bytes.toBytes("col1value"));
        g.addColumn(Bytes.toBytes("ColumnFam1"), Bytes.toBytes("1"));
        Result result = table.get(g);
        System.out.println("Get:   OUTPUT     " + result);

我有任何方法通过传递get中的值来获得columnfamily名称和列名，我也尝试过不使用g.addColumn行。它不给任何东西

Answer 1

Get g=new Get(bytes.tobytes("col1value“））；不起作用，因为该行不存在。您必须提供刚刚插入到get中的rowkey：

HTable table = new HTable(config, tablename);
byte [] row1 = Bytes.toBytes("KeyIn");
Put p1 = new Put(row1);
byte [] databytes = Bytes.toBytes("ColumnFam1");
p1.add(databytes, Bytes.toBytes("1"), Bytes.toBytes("col1value"));
table.put(p1);
Get g = new Get(row1);
//g.addColumn(Bytes.toBytes("ColumnFam1"), Bytes.toBytes("1")); // Not needed if you want to retrieve all families/columns
Result result = table.get(g);
System.out.println("Get:   OUTPUT     " + result);

如果知道列的名称（如其所示），则可以直接访问该值：

if (result.containsColumn(databytes, Bytes.toBytes("1"))) {
    System.out.println("Value: " + Bytes.toStringBinary(result.getColumnLatest(databytes, Bytes.toBytes("1"))));
}

或者，如果要遍历所有检索到的列：

Result result = table.get(get);
if (result!=null) {
    System.out.println(result);
    Set<Entry<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>>> entries = result.getMap().entrySet();
    for(Entry<byte[], NavigableMap<byte[], NavigableMap<Long, byte[]>>> familyEntry: entries) {
        byte[] family = familyEntry.getKey();
        for(Entry<byte[], NavigableMap<Long, byte[]>> columnEntry: familyEntry.getValue().entrySet()) {
            byte[] column = columnEntry.getKey();
            System.out.println("Found column "+Bytes.toStringBinary(family)+":"+Bytes.toStringBinary(column));
            if (columnEntry.getValue().size()>0) {
                Entry<Long, byte[]> valueEntry = columnEntry.getValue().firstEntry();
                System.out.println("  Found value "+Bytes.toStringBinary(valueEntry.getValue())+" with timestamp "+valueEntry.getKey());    
            }
        }
    }
}

• 为了简单起见，我只读取每个列的最新值，但是如果需要所有版本*
，您可以迭代 columnentry.getvalue().entryset()