写入多个hbase表,如何使用context.write(hkey,put)?

jtjikinw  于 2021-06-01  发布在  Hadoop
关注(0)|答案(0)|浏览(249)

我是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 不是表名,而是表示表中的某个特定行。
我该怎么处理?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题