我是hadoop mapreduce的新手。我想从我的reducer函数执行多个表的写操作。如果有什么东西被写到表1中,那么我也希望表2中有同样的内容。
我浏览了hbase中的write to multiple tables之类的文章,并检查了“multitableoutputformat”。但我不明白的是,根据减速机中的post函数,我应该只使用
context.write(new ImmutableBytesWritable(Bytes.toBytes("tableName1")),put1); context.write(new ImmutableBytesWritable(Bytes.toBytes("tableName2")),put2);
我不明白,如果我们这样做,那么我们在哪里定义要更新值的行呢。例如,我看到一些代码片段,并将它们作为 context.write(hkey, put)
. 我觉得呢 hkey
不是表名,而是表示表中的某个特定行。
我该怎么处理?
暂无答案!
目前还没有任何答案,快来回答吧!