http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83bf6175/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html index 1bafdbf..6bbb4d4 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; <br> <pre>@InterfaceAudience.Private @InterfaceStability.Evolving -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.61">BufferedMutatorImpl</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.63">BufferedMutatorImpl</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></pre> <div class="block"><p> @@ -203,6 +203,14 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#currentWriteBufferSize">currentWriteBufferSize</a></span></code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#executedWriteBufferPeriodicFlushes">executedWriteBufferPeriodicFlushes</a></span></code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#firstRecordInBufferTimestamp">firstRecordInBufferTimestamp</a></span></code> </td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#listener">listener</a></span></code> </td> </tr> @@ -242,6 +250,18 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato </tr> <tr class="altColor"> <td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#writeBufferPeriodicFlushTimeoutMs">writeBufferPeriodicFlushTimeoutMs</a></span></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Timer.html?is-external=true"; title="class or interface in java.util">Timer</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#writeBufferPeriodicFlushTimer">writeBufferPeriodicFlushTimer</a></span></code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#writeBufferPeriodicFlushTimerTickMs">writeBufferPeriodicFlushTimerTickMs</a></span></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#writeBufferSize">writeBufferSize</a></span></code> </td> </tr> </table> @@ -250,7 +270,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <!-- --> </a> <h3>Fields inherited from interface org.apache.hadoop.hbase.client.<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></h3> -<code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#CLASSNAME_KEY">CLASSNAME_KEY</a></code></li> +<code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#CLASSNAME_KEY">CLASSNAME_KEY</a>, <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS">MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS</a></code></li> </ul> </li> </ul> @@ -325,57 +345,85 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getCurrentWriteBufferSize--">getCurrentWriteBufferSize</a></span>()</code> </td> </tr> <tr id="i6" class="altColor"> +<td class="colFirst"><code>protected long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getExecutedWriteBufferPeriodicFlushes--">getExecutedWriteBufferPeriodicFlushes</a></span>()</code> </td> +</tr> +<tr id="i7" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getName--">getName</a></span>()</code> <div class="block">Gets the fully qualified table name instance of the table that this BufferedMutator writes to.</div> </td> </tr> -<tr id="i7" class="rowColor"> +<tr id="i8" class="altColor"> <td class="colFirst"><code>(package private) <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getPool--">getPool</a></span>()</code> </td> </tr> -<tr id="i8" class="altColor"> +<tr id="i9" class="rowColor"> +<td class="colFirst"><code>long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getWriteBufferPeriodicFlushTimeoutMs--">getWriteBufferPeriodicFlushTimeoutMs</a></span>()</code> +<div class="block">Returns the current periodic flush timeout value in milliseconds.</div> +</td> +</tr> +<tr id="i10" class="altColor"> +<td class="colFirst"><code>long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getWriteBufferPeriodicFlushTimerTickMs--">getWriteBufferPeriodicFlushTimerTickMs</a></span>()</code> +<div class="block">Returns the current periodic flush timertick interval in milliseconds.</div> +</td> +</tr> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#getWriteBufferSize--">getWriteBufferSize</a></span>()</code> <div class="block">Returns the maximum size in bytes of the write buffer for this HTable.</div> </td> </tr> -<tr id="i9" class="rowColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#mutate-java.util.List-">mutate</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a>> ms)</code> <div class="block">Send some <a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client"><code>Mutation</code></a>s to the table.</div> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#mutate-org.apache.hadoop.hbase.client.Mutation-">mutate</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a> m)</code> <div class="block">Sends a <a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client"><code>Mutation</code></a> to the table.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#setOperationTimeout-int-">setOperationTimeout</a></span>(int operationTimeout)</code> <div class="block">Set operation timeout for this mutator instance</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#setRpcTimeout-int-">setRpcTimeout</a></span>(int rpcTimeout)</code> <div class="block">Set rpc timeout for this mutator instance</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i16" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#setWriteBufferPeriodicFlush-long-long-">setWriteBufferPeriodicFlush</a></span>(long timeoutMs, + long timerTickMs)</code> +<div class="block">Sets the maximum time before the buffer is automatically flushed.</div> +</td> +</tr> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>(package private) int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#size--">size</a></span>()</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i18" class="altColor"> +<td class="colFirst"><code>private void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#timerCallbackForWriteBufferPeriodicFlush--">timerCallbackForWriteBufferPeriodicFlush</a></span>()</code> </td> +</tr> +<tr id="i19" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#validatePut-org.apache.hadoop.hbase.client.Put-">validatePut</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/Put.html" title="class in org.apache.hadoop.hbase.client">Put</a> put)</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i20" class="altColor"> <td class="colFirst"><code>private <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcessTask.html" title="class in org.apache.hadoop.hbase.client">AsyncProcessTask</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#wrapAsyncProcessTask-org.apache.hadoop.hbase.client.BufferedMutatorImpl.QueueRowAccess-">wrapAsyncProcessTask</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorImpl.QueueRowAccess</a> taker)</code> -<div class="block">Reuse the AsyncProcessTask when calling <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#backgroundFlushCommits-boolean-"><code>backgroundFlushCommits(boolean)</code></a>.</div> +<div class="block">Reuse the AsyncProcessTask when calling + <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#backgroundFlushCommits-boolean-"><code>backgroundFlushCommits(boolean)</code></a>.</div> </td> </tr> </table> @@ -386,6 +434,13 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <h3>Methods inherited from class java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></h3> <code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-"; title="class or interface in java.lang">equals</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--"; title="class or interface in java.lang">finalize</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--"; title="class or interface in java.lang">getClass</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--"; title="class or interface in java.lang">hashCode</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--"; title="class or interface in java.lang">notify</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang /Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--"; title="class or interface in java.lang">toString</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-"; title="class or interface in java.lang">wait</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-"; title="class or interface in java.lang">wait</a></code></li> </ul> +<ul class="blockList"> +<li class="blockList"><a name="methods.inherited.from.class.org.apache.hadoop.hbase.client.BufferedMutator"> +<!-- --> +</a> +<h3>Methods inherited from interface org.apache.hadoop.hbase.client.<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></h3> +<code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#disableWriteBufferPeriodicFlush--">disableWriteBufferPeriodicFlush</a>, <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#setWriteBufferPeriodicFlush-long-">setWriteBufferPeriodicFlush</a></code></li> +</ul> </li> </ul> </li> @@ -406,7 +461,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.slf4j.Logger <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.63">LOG</a></pre> +<pre>private static final org.slf4j.Logger <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.65">LOG</a></pre> </li> </ul> <a name="listener"> @@ -415,7 +470,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>listener</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.65">listener</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.67">listener</a></pre> </li> </ul> <a name="tableName"> @@ -424,7 +479,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>tableName</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.67">tableName</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.69">tableName</a></pre> </li> </ul> <a name="conf"> @@ -433,7 +488,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>conf</h4> -<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.69">conf</a></pre> +<pre>private final org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.71">conf</a></pre> </li> </ul> <a name="writeAsyncBuffer"> @@ -442,7 +497,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>writeAsyncBuffer</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentLinkedQueue</a><<a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.70">writeAsyncBuffer</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html?is-external=true"; title="class or interface in java.util.concurrent">ConcurrentLinkedQueue</a><<a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a>> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.72">writeAsyncBuffer</a></pre> </li> </ul> <a name="currentWriteBufferSize"> @@ -451,7 +506,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>currentWriteBufferSize</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.71">currentWriteBufferSize</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.73">currentWriteBufferSize</a></pre> </li> </ul> <a name="undealtMutationCount"> @@ -460,7 +515,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>undealtMutationCount</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.76">undealtMutationCount</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.78">undealtMutationCount</a></pre> <div class="block">Count the size of <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#writeAsyncBuffer"><code>writeAsyncBuffer</code></a>. The <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedQueue.html?is-external=true#size--"; title="class or interface in java.util.concurrent"><code>ConcurrentLinkedQueue.size()</code></a> is NOT a constant-time operation.</div> </li> @@ -471,7 +526,34 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>writeBufferSize</h4> -<pre>private final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.77">writeBufferSize</a></pre> +<pre>private final long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.79">writeBufferSize</a></pre> +</li> +</ul> +<a name="writeBufferPeriodicFlushTimeoutMs"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>writeBufferPeriodicFlushTimeoutMs</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.81">writeBufferPeriodicFlushTimeoutMs</a></pre> +</li> +</ul> +<a name="writeBufferPeriodicFlushTimerTickMs"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>writeBufferPeriodicFlushTimerTickMs</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.82">writeBufferPeriodicFlushTimerTickMs</a></pre> +</li> +</ul> +<a name="writeBufferPeriodicFlushTimer"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>writeBufferPeriodicFlushTimer</h4> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Timer.html?is-external=true"; title="class or interface in java.util">Timer</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.83">writeBufferPeriodicFlushTimer</a></pre> </li> </ul> <a name="maxKeyValueSize"> @@ -480,7 +562,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>maxKeyValueSize</h4> -<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.78">maxKeyValueSize</a></pre> +<pre>private final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.85">maxKeyValueSize</a></pre> </li> </ul> <a name="pool"> @@ -489,7 +571,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>pool</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.79">pool</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.86">pool</a></pre> </li> </ul> <a name="rpcTimeout"> @@ -498,7 +580,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>rpcTimeout</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.80">rpcTimeout</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.87">rpcTimeout</a></pre> </li> </ul> <a name="operationTimeout"> @@ -507,7 +589,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>operationTimeout</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.81">operationTimeout</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.88">operationTimeout</a></pre> </li> </ul> <a name="cleanupPoolOnClose"> @@ -516,7 +598,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>cleanupPoolOnClose</h4> -<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.82">cleanupPoolOnClose</a></pre> +<pre>private final boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.89">cleanupPoolOnClose</a></pre> </li> </ul> <a name="closed"> @@ -525,16 +607,34 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>closed</h4> -<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.83">closed</a></pre> +<pre>private volatile boolean <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.90">closed</a></pre> </li> </ul> <a name="ap"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>ap</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.84">ap</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.91">ap</a></pre> +</li> +</ul> +<a name="firstRecordInBufferTimestamp"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>firstRecordInBufferTimestamp</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.220">firstRecordInBufferTimestamp</a></pre> +</li> +</ul> +<a name="executedWriteBufferPeriodicFlushes"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>executedWriteBufferPeriodicFlushes</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.221">executedWriteBufferPeriodicFlushes</a></pre> </li> </ul> </li> @@ -551,7 +651,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>BufferedMutatorImpl</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.87">BufferedMutatorImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> conn, +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.94">BufferedMutatorImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> conn, <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> params, <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess</a> ap)</pre> </li> @@ -562,7 +662,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockListLast"> <li class="blockList"> <h4>BufferedMutatorImpl</h4> -<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.113">BufferedMutatorImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> conn, +<pre><a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.139">BufferedMutatorImpl</a>(<a href="../../../../../org/apache/hadoop/hbase/client/ClusterConnection.html" title="interface in org.apache.hadoop.hbase.client">ClusterConnection</a> conn, <a href="../../../../../org/apache/hadoop/hbase/client/RpcRetryingCallerFactory.html" title="class in org.apache.hadoop.hbase.client">RpcRetryingCallerFactory</a> rpcCallerFactory, <a href="../../../../../org/apache/hadoop/hbase/ipc/RpcControllerFactory.html" title="class in org.apache.hadoop.hbase.ipc">RpcControllerFactory</a> rpcFactory, <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> params)</pre> @@ -582,7 +682,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getPool</h4> -<pre><a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.121">getPool</a>()</pre> +<pre><a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.147">getPool</a>()</pre> </li> </ul> <a name="getAsyncProcess--"> @@ -591,7 +691,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getAsyncProcess</h4> -<pre><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.126">getAsyncProcess</a>()</pre> +<pre><a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcess.html" title="class in org.apache.hadoop.hbase.client">AsyncProcess</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.152">getAsyncProcess</a>()</pre> </li> </ul> <a name="getName--"> @@ -600,7 +700,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getName</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.131">getName</a>()</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.157">getName</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getName--">BufferedMutator</a></code></span></div> <div class="block">Gets the fully qualified table name instance of the table that this BufferedMutator writes to.</div> <dl> @@ -615,7 +715,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getConfiguration</h4> -<pre>public org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.136">getConfiguration</a>()</pre> +<pre>public org.apache.hadoop.conf.Configuration <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.162">getConfiguration</a>()</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getConfiguration--">BufferedMutator</a></code></span></div> <div class="block">Returns the <code>Configuration</code> object used by this instance. <p> @@ -633,7 +733,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>mutate</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.141">mutate</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a> m) +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.167">mutate</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a> m) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a>, <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a></pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#mutate-org.apache.hadoop.hbase.client.Mutation-">BufferedMutator</a></code></span></div> @@ -656,7 +756,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>mutate</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.147">mutate</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a>> ms) +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.173">mutate</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><? extends <a href="../../../../../org/apache/hadoop/hbase/client/Mutation.html" title="class in org.apache.hadoop.hbase.client">Mutation</a>> ms) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a>, <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a></pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#mutate-java.util.List-">BufferedMutator</a></code></span></div> @@ -674,13 +774,31 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato </dl> </li> </ul> +<a name="getExecutedWriteBufferPeriodicFlushes--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getExecutedWriteBufferPeriodicFlushes</h4> +<pre>protected long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.216">getExecutedWriteBufferPeriodicFlushes</a>()</pre> +</li> +</ul> +<a name="timerCallbackForWriteBufferPeriodicFlush--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>timerCallbackForWriteBufferPeriodicFlush</h4> +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.223">timerCallbackForWriteBufferPeriodicFlush</a>()</pre> +</li> +</ul> <a name="validatePut-org.apache.hadoop.hbase.client.Put-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>validatePut</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.186">validatePut</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Put.html" title="class in org.apache.hadoop.hbase.client">Put</a> put) +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.241">validatePut</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Put.html" title="class in org.apache.hadoop.hbase.client">Put</a> put) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/IllegalArgumentException.html?is-external=true"; title="class or interface in java.lang">IllegalArgumentException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -694,7 +812,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.191">close</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.246">close</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#close--">BufferedMutator</a></code></span></div> <div class="block">Performs a <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#flush--"><code>BufferedMutator.flush()</code></a> and releases any resources held.</div> @@ -716,7 +834,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>flush</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.221">flush</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.280">flush</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a>, <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a></pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#flush--">BufferedMutator</a></code></span></div> @@ -737,7 +855,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>backgroundFlushCommits</h4> -<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.236">backgroundFlushCommits</a>(boolean synchronous) +<pre>private void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.295">backgroundFlushCommits</a>(boolean synchronous) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true"; title="class or interface in java.io">InterruptedIOException</a>, <a href="../../../../../org/apache/hadoop/hbase/client/RetriesExhaustedWithDetailsException.html" title="class in org.apache.hadoop.hbase.client">RetriesExhaustedWithDetailsException</a></pre> <div class="block">Send the operations in the buffer to the servers. Does not wait for the server's answer. If @@ -759,8 +877,9 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>wrapAsyncProcessTask</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcessTask.html" title="class in org.apache.hadoop.hbase.client">AsyncProcessTask</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.284">wrapAsyncProcessTask</a>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorImpl.QueueRowAccess</a> taker)</pre> -<div class="block">Reuse the AsyncProcessTask when calling <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#backgroundFlushCommits-boolean-"><code>backgroundFlushCommits(boolean)</code></a>.</div> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/AsyncProcessTask.html" title="class in org.apache.hadoop.hbase.client">AsyncProcessTask</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.344">wrapAsyncProcessTask</a>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.QueueRowAccess.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorImpl.QueueRowAccess</a> taker)</pre> +<div class="block">Reuse the AsyncProcessTask when calling + <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#backgroundFlushCommits-boolean-"><code>backgroundFlushCommits(boolean)</code></a>.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>taker</code> - access the inner buffer.</dd> @@ -775,7 +894,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getWriteBufferSize</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.308">getWriteBufferSize</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.368">getWriteBufferSize</a>()</pre> <div class="block">Returns the maximum size in bytes of the write buffer for this HTable. <p> The default value comes from the configuration parameter <code>hbase.client.write.buffer</code>.</div> @@ -787,13 +906,72 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato </dl> </li> </ul> +<a name="setWriteBufferPeriodicFlush-long-long-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>setWriteBufferPeriodicFlush</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.373">setWriteBufferPeriodicFlush</a>(long timeoutMs, + long timerTickMs)</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#setWriteBufferPeriodicFlush-long-long-">BufferedMutator</a></code></span></div> +<div class="block">Sets the maximum time before the buffer is automatically flushed.</div> +<dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#setWriteBufferPeriodicFlush-long-long-">setWriteBufferPeriodicFlush</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></code></dd> +<dt><span class="paramLabel">Parameters:</span></dt> +<dd><code>timeoutMs</code> - The maximum number of milliseconds how long records may be buffered + before they are flushed. Set to 0 to disable.</dd> +<dd><code>timerTickMs</code> - The number of milliseconds between each check if the + timeout has been exceeded. Must be 100ms (as defined in + <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS"><code>BufferedMutator.MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS</code></a>) + or larger to avoid performance problems.</dd> +</dl> +</li> +</ul> +<a name="getWriteBufferPeriodicFlushTimeoutMs--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWriteBufferPeriodicFlushTimeoutMs</h4> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.405">getWriteBufferPeriodicFlushTimeoutMs</a>()</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getWriteBufferPeriodicFlushTimeoutMs--">BufferedMutator</a></code></span></div> +<div class="block">Returns the current periodic flush timeout value in milliseconds.</div> +<dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getWriteBufferPeriodicFlushTimeoutMs--">getWriteBufferPeriodicFlushTimeoutMs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></code></dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>The maximum number of milliseconds how long records may be buffered before they + are flushed. The value 0 means this is disabled.</dd> +</dl> +</li> +</ul> +<a name="getWriteBufferPeriodicFlushTimerTickMs--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWriteBufferPeriodicFlushTimerTickMs</h4> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.410">getWriteBufferPeriodicFlushTimerTickMs</a>()</pre> +<div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getWriteBufferPeriodicFlushTimerTickMs--">BufferedMutator</a></code></span></div> +<div class="block">Returns the current periodic flush timertick interval in milliseconds.</div> +<dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#getWriteBufferPeriodicFlushTimerTickMs--">getWriteBufferPeriodicFlushTimerTickMs</a></code> in interface <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator</a></code></dd> +<dt><span class="returnLabel">Returns:</span></dt> +<dd>The number of milliseconds between each check if the timeout has been exceeded. + This value only has a real meaning if the timeout has been set to > 0</dd> +</dl> +</li> +</ul> <a name="setRpcTimeout-int-"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>setRpcTimeout</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.313">setRpcTimeout</a>(int rpcTimeout)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.415">setRpcTimeout</a>(int rpcTimeout)</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#setRpcTimeout-int-">BufferedMutator</a></code></span></div> <div class="block">Set rpc timeout for this mutator instance</div> <dl> @@ -808,7 +986,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>setOperationTimeout</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.318">setOperationTimeout</a>(int operationTimeout)</pre> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.420">setOperationTimeout</a>(int operationTimeout)</pre> <div class="block"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html#setOperationTimeout-int-">BufferedMutator</a></code></span></div> <div class="block">Set operation timeout for this mutator instance</div> <dl> @@ -823,7 +1001,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockList"> <li class="blockList"> <h4>getCurrentWriteBufferSize</h4> -<pre>long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.323">getCurrentWriteBufferSize</a>()</pre> +<pre>long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.425">getCurrentWriteBufferSize</a>()</pre> </li> </ul> <a name="size--"> @@ -832,7 +1010,7 @@ implements <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutato <ul class="blockListLast"> <li class="blockList"> <h4>size</h4> -<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.328">size</a>()</pre> +<pre>int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorImpl.html#line.430">size</a>()</pre> </li> </ul> </li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83bf6175/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorParams.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorParams.html b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorParams.html index 6950788..3166253 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorParams.html +++ b/devapidocs/org/apache/hadoop/hbase/client/BufferedMutatorParams.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Public -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.31">BufferedMutatorParams</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.30">BufferedMutatorParams</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a> implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable.html?is-external=true"; title="class or interface in java.lang">Cloneable</a></pre> <div class="block">Parameters for instantiating a <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.html" title="interface in org.apache.hadoop.hbase.client"><code>BufferedMutator</code></a>.</div> @@ -170,6 +170,14 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable </tr> <tr class="altColor"> <td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#writeBufferPeriodicFlushTimeoutMs">writeBufferPeriodicFlushTimeoutMs</a></span></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>private long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#writeBufferPeriodicFlushTimerTickMs">writeBufferPeriodicFlushTimerTickMs</a></span></code> </td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#writeBufferSize">writeBufferSize</a></span></code> </td> </tr> </table> @@ -238,21 +246,29 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable </tr> <tr id="i8" class="altColor"> <td class="colFirst"><code>long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#getWriteBufferSize--">getWriteBufferSize</a></span>()</code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#getWriteBufferPeriodicFlushTimeoutMs--">getWriteBufferPeriodicFlushTimeoutMs</a></span>()</code> </td> </tr> <tr id="i9" class="rowColor"> +<td class="colFirst"><code>long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#getWriteBufferPeriodicFlushTimerTickMs--">getWriteBufferPeriodicFlushTimerTickMs</a></span>()</code> </td> +</tr> +<tr id="i10" class="altColor"> +<td class="colFirst"><code>long</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#getWriteBufferSize--">getWriteBufferSize</a></span>()</code> </td> +</tr> +<tr id="i11" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#implementationClassName-java.lang.String-">implementationClassName</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> implementationClassName)</code> <div class="block">Specify a BufferedMutator implementation other than the default.</div> </td> </tr> -<tr id="i10" class="altColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#listener-org.apache.hadoop.hbase.client.BufferedMutator.ExceptionListener-">listener</a></span>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> listener)</code> <div class="block">Override the default error handler.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#maxKeyValueSize-int-">maxKeyValueSize</a></span>(int maxKeyValueSize)</code> <div class="block">Override the maximum key-value size specified by the provided <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client"><code>Connection</code></a>'s @@ -260,22 +276,34 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <code>hbase.client.keyvalue.maxsize</code>.</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#opertationTimeout-int-">opertationTimeout</a></span>(int operationTimeout)</code> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#pool-java.util.concurrent.ExecutorService-">pool</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</code> <div class="block">Override the default executor pool defined by the <code>hbase.htable.threads.*</code> configuration values.</div> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#rpcTimeout-int-">rpcTimeout</a></span>(int rpcTimeout)</code> </td> </tr> -<tr id="i15" class="rowColor"> +<tr id="i17" class="rowColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#setWriteBufferPeriodicFlushTimeoutMs-long-">setWriteBufferPeriodicFlushTimeoutMs</a></span>(long timeoutMs)</code> +<div class="block">Set the max timeout before the buffer is automatically flushed.</div> +</td> +</tr> +<tr id="i18" class="altColor"> +<td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#setWriteBufferPeriodicFlushTimerTickMs-long-">setWriteBufferPeriodicFlushTimerTickMs</a></span>(long timerTickMs)</code> +<div class="block">Set the TimerTick how often the buffer timeout if checked.</div> +</td> +</tr> +<tr id="i19" class="rowColor"> <td class="colFirst"><code><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html#writeBufferSize-long-">writeBufferSize</a></span>(long writeBufferSize)</code> <div class="block">Override the write buffer size specified by the provided <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client"><code>Connection</code></a>'s @@ -311,7 +339,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>UNSET</h4> -<pre>static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.33">UNSET</a></pre> +<pre>static final int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.32">UNSET</a></pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.client.BufferedMutatorParams.UNSET">Constant Field Values</a></dd> @@ -324,7 +352,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>tableName</h4> -<pre>private final <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.35">tableName</a></pre> +<pre>private final <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.34">tableName</a></pre> </li> </ul> <a name="writeBufferSize"> @@ -333,7 +361,25 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>writeBufferSize</h4> -<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.36">writeBufferSize</a></pre> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.35">writeBufferSize</a></pre> +</li> +</ul> +<a name="writeBufferPeriodicFlushTimeoutMs"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>writeBufferPeriodicFlushTimeoutMs</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.36">writeBufferPeriodicFlushTimeoutMs</a></pre> +</li> +</ul> +<a name="writeBufferPeriodicFlushTimerTickMs"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>writeBufferPeriodicFlushTimerTickMs</h4> +<pre>private long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.37">writeBufferPeriodicFlushTimerTickMs</a></pre> </li> </ul> <a name="maxKeyValueSize"> @@ -342,7 +388,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>maxKeyValueSize</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.37">maxKeyValueSize</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.38">maxKeyValueSize</a></pre> </li> </ul> <a name="pool"> @@ -351,7 +397,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>pool</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.38">pool</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.39">pool</a></pre> </li> </ul> <a name="implementationClassName"> @@ -360,7 +406,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>implementationClassName</h4> -<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.39">implementationClassName</a></pre> +<pre>private <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.40">implementationClassName</a></pre> </li> </ul> <a name="rpcTimeout"> @@ -369,7 +415,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>rpcTimeout</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.40">rpcTimeout</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.41">rpcTimeout</a></pre> </li> </ul> <a name="operationTimeout"> @@ -378,7 +424,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>operationTimeout</h4> -<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.41">operationTimeout</a></pre> +<pre>private int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.42">operationTimeout</a></pre> </li> </ul> <a name="listener"> @@ -387,7 +433,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockListLast"> <li class="blockList"> <h4>listener</h4> -<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.42">listener</a></pre> +<pre>private <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.43">listener</a></pre> </li> </ul> </li> @@ -404,7 +450,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockListLast"> <li class="blockList"> <h4>BufferedMutatorParams</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.51">BufferedMutatorParams</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName)</pre> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.52">BufferedMutatorParams</a>(<a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName)</pre> </li> </ul> </li> @@ -421,7 +467,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getTableName</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.55">getTableName</a>()</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.56">getTableName</a>()</pre> </li> </ul> <a name="getWriteBufferSize--"> @@ -430,7 +476,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getWriteBufferSize</h4> -<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.59">getWriteBufferSize</a>()</pre> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.60">getWriteBufferSize</a>()</pre> </li> </ul> <a name="rpcTimeout-int-"> @@ -439,7 +485,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>rpcTimeout</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.63">rpcTimeout</a>(int rpcTimeout)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.64">rpcTimeout</a>(int rpcTimeout)</pre> </li> </ul> <a name="getRpcTimeout--"> @@ -448,7 +494,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getRpcTimeout</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.68">getRpcTimeout</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.69">getRpcTimeout</a>()</pre> </li> </ul> <a name="opertationTimeout-int-"> @@ -457,7 +503,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>opertationTimeout</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.72">opertationTimeout</a>(int operationTimeout)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.73">opertationTimeout</a>(int operationTimeout)</pre> </li> </ul> <a name="getOperationTimeout--"> @@ -466,7 +512,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getOperationTimeout</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.77">getOperationTimeout</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.78">getOperationTimeout</a>()</pre> </li> </ul> <a name="writeBufferSize-long-"> @@ -475,19 +521,57 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>writeBufferSize</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.86">writeBufferSize</a>(long writeBufferSize)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.87">writeBufferSize</a>(long writeBufferSize)</pre> <div class="block">Override the write buffer size specified by the provided <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client"><code>Connection</code></a>'s <code>Configuration</code> instance, via the configuration key <code>hbase.client.write.buffer</code>.</div> </li> </ul> +<a name="getWriteBufferPeriodicFlushTimeoutMs--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWriteBufferPeriodicFlushTimeoutMs</h4> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.92">getWriteBufferPeriodicFlushTimeoutMs</a>()</pre> +</li> +</ul> +<a name="setWriteBufferPeriodicFlushTimeoutMs-long-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>setWriteBufferPeriodicFlushTimeoutMs</h4> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.99">setWriteBufferPeriodicFlushTimeoutMs</a>(long timeoutMs)</pre> +<div class="block">Set the max timeout before the buffer is automatically flushed.</div> +</li> +</ul> +<a name="getWriteBufferPeriodicFlushTimerTickMs--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getWriteBufferPeriodicFlushTimerTickMs</h4> +<pre>public long <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.104">getWriteBufferPeriodicFlushTimerTickMs</a>()</pre> +</li> +</ul> +<a name="setWriteBufferPeriodicFlushTimerTickMs-long-"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>setWriteBufferPeriodicFlushTimerTickMs</h4> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.111">setWriteBufferPeriodicFlushTimerTickMs</a>(long timerTickMs)</pre> +<div class="block">Set the TimerTick how often the buffer timeout if checked.</div> +</li> +</ul> <a name="getMaxKeyValueSize--"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>getMaxKeyValueSize</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.91">getMaxKeyValueSize</a>()</pre> +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.116">getMaxKeyValueSize</a>()</pre> </li> </ul> <a name="maxKeyValueSize-int-"> @@ -496,7 +580,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>maxKeyValueSize</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.100">maxKeyValueSize</a>(int maxKeyValueSize)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.125">maxKeyValueSize</a>(int maxKeyValueSize)</pre> <div class="block">Override the maximum key-value size specified by the provided <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client"><code>Connection</code></a>'s <code>Configuration</code> instance, via the configuration key <code>hbase.client.keyvalue.maxsize</code>.</div> @@ -508,7 +592,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getPool</h4> -<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.105">getPool</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.130">getPool</a>()</pre> </li> </ul> <a name="pool-java.util.concurrent.ExecutorService-"> @@ -517,7 +601,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>pool</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.113">pool</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.138">pool</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool)</pre> <div class="block">Override the default executor pool defined by the <code>hbase.htable.threads.*</code> configuration values.</div> </li> @@ -528,7 +612,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getImplementationClassName</h4> -<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.122">getImplementationClassName</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.147">getImplementationClassName</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>Name of the class we will use when we construct a @@ -542,7 +626,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>implementationClassName</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.130">implementationClassName</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> implementationClassName)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.155">implementationClassName</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> implementationClassName)</pre> <div class="block">Specify a BufferedMutator implementation other than the default.</div> <dl> <dt><span class="paramLabel">Parameters:</span></dt> @@ -556,7 +640,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>getListener</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.135">getListener</a>()</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.160">getListener</a>()</pre> </li> </ul> <a name="listener-org.apache.hadoop.hbase.client.BufferedMutator.ExceptionListener-"> @@ -565,7 +649,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockList"> <li class="blockList"> <h4>listener</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.142">listener</a>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> listener)</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.167">listener</a>(<a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutator.ExceptionListener.html" title="interface in org.apache.hadoop.hbase.client">BufferedMutator.ExceptionListener</a> listener)</pre> <div class="block">Override the default error handler. Default handler simply rethrows the exception.</div> </li> </ul> @@ -575,7 +659,7 @@ implements <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Cloneable <ul class="blockListLast"> <li class="blockList"> <h4>clone</h4> -<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.155">clone</a>()</pre> +<pre>public <a href="../../../../../org/apache/hadoop/hbase/client/BufferedMutatorParams.html" title="class in org.apache.hadoop.hbase.client">BufferedMutatorParams</a> <a href="../../../../../src-html/org/apache/hadoop/hbase/client/BufferedMutatorParams.html#line.180">clone</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Overrides:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--"; title="class or interface in java.lang">clone</a></code> in class <code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></code></dd>
