java - 如何在 Java 中获取 HBase 的行键

Question

映射器任务配置为:

TableMapReduceUtil.initTableMapperJob("PaperAbout1", scan, InputMapper.class, Text.class, Text.class, job);

而map函数头如下:

protected void map(ImmutableBytesWritable row, Result value,
            Mapper<ImmutableBytesWritable, Result, Text, Text>.Context context)
            throws IOException, InterruptedException {

任何需要检索的列值都可以通过以下方式检索:

String columnValue = Bytes.toString(result.getValue(Bytes.toBytes("ColumnFamily"), Bytes.toBytes("column"))));

map任务中如何获取扫描行的key？

Answer 1

row.get() 

将返回 key 的字节数组。您当然必须将其解析为您使用 Bytes.toDatatype() 方法用作 key 的正确数据类型。