Merge pull request #1696 from koo-taejin/#1683

Support the async put API provided by HTableMultiplexer to improve th…
This commit is contained in:
koo-taejin
2016-04-19 10:51:02 +09:00
2 changed files with 10 additions and 4 deletions
@@ -33,10 +33,10 @@
<prop key="hbase.ipc.client.socket.timeout.write">${hbase.ipc.client.socket.timeout.write}</prop>
<!-- hbase async put operation. -->
<prop key="hbase.client.async.enable">${hbase.client.async.enable}</prop>
<prop key="hbase.client.async.in.queuesize">${hbase.client.async.in.queuesize}</prop>
<prop key="hbase.tablemultiplexer.flush.period.ms">${hbase.client.async.flush.period.ms}</prop>
<prop key="hbase.client.max.retries.in.queue">${hbase.client.async.max.retries.in.queue}</prop>
<prop key="hbase.client.async.enable">${hbase.client.async.enable?false}</prop>
<prop key="hbase.client.async.in.queuesize">${hbase.client.async.in.queuesize?10000}</prop>
<prop key="hbase.tablemultiplexer.flush.period.ms">${hbase.client.async.flush.period.ms?100}</prop>
<prop key="hbase.client.max.retries.in.queue">${hbase.client.async.max.retries.in.queue?10}</prop>
</props>
</property>
</bean>
@@ -20,6 +20,12 @@
<prop key="hbase.ipc.client.socket.timeout.read">${hbase.ipc.client.socket.timeout.read}</prop>
<!-- socket write timeout. hbase default: 600000-->
<prop key="hbase.ipc.client.socket.timeout.write">${hbase.ipc.client.socket.timeout.write}</prop>
<!-- hbase async put operation. -->
<prop key="hbase.client.async.enable">${hbase.client.async.enable?false}</prop>
<prop key="hbase.client.async.in.queuesize">${hbase.client.async.in.queuesize?10000}</prop>
<prop key="hbase.tablemultiplexer.flush.period.ms">${hbase.client.async.flush.period.ms?100}</prop>
<prop key="hbase.client.max.retries.in.queue">${hbase.client.async.max.retries.in.queue?10}</prop>
</props>
</property>
</bean>