问题描述
我正在使用context.write()
与put从Mapper写入HBase。
根据此 , context.write()
不会立即刷新,并在缓冲区被异步设置为服务器之前等待缓冲区已满。
如何设置Mapper输出的缓冲区大小。 目的是通过调整缓冲区大小来减少对HBase表的RPC调用。
1楼
HBase客户端缓冲区可以通过参数hbase.client.write.buffer进行配置
除了增加客户端缓冲区之外,您还可以此以优化对hbase的写入。