0

我正在使用 HBase 表来存储事件，并且我想使用其响应事件的输出来更新请求事件。这两个值都存储在 HBase 表中的两个不同行上。

这是我遇到的困境。我想使用一个 mapreduce 作业，它将接收所有响应行，并使用响应行的状态更新请求行。响应和请求都具有匹配的用户 ID，但行由相关 ID 索引。rowkey 的格式是 (event_corrID_userID)。从现在到那时，相关 ID 可能已更改，但用户 ID 将始终相同。

这就是我的全部情况。在 mapreduce 期间如何在表中（在其他行中）进行搜索？这是我到目前为止所拥有的：

public class MapReducer {
    public static void main(String[] args){
        Configuration config = HBaseConfiguration.create();
        try{
            String startRow = "response_";
            String endRow = "responsf_";
            Job job = new Job(config, "TestAuditingResponse");
            job.setJarByClass(MapReducer.class);
            Scan scan = new Scan(Bytes.toBytes(startRow), Bytes.toBytes(endRow));
            scan.setCaching(500);
            scan.setCacheBlocks(false);

            TableMapReduceUtil.initTableMapperJob(
                    "test",
                    scan,
                    mapper.class,
                    null,
                    null,
                    job);
            TableMapReduceUtil.initTableReducerJob(
                    "test",
                    null,
                    job);
            job.setNumReduceTasks(0);

            boolean b = job.waitForCompletion(true);
            if(!b){
                throw new IOException("ERROR WITH JOB");
            }
        } catch(IOException e){
            e.printStackTrace();
        } catch(ClassNotFoundException e){
            e.printStackTrace();
        } catch(InterruptedException e){
            e.printStackTrace();
        }
    }
    public static class mapper extends TableMapper<ImmutableBytesWritable, Put> {
        public void map(ImmutableBytesWritable row, Result value, Context context) throws IOException, InterruptedException {
            //TODO find row to put new value into
        }
    }

}

有谁知道我该怎么做？或者以分布式/易于运行的方式基于表中的其他行更新表的更好/更快的方法？

4

1 回答 1

0

似乎您要“加入”一张内部表格。你可以检查这个新功能。

于 2013-08-06T15:56:20.367 回答