http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/apidocs/org/apache/hadoop/hbase/client/class-use/Connection.html ---------------------------------------------------------------------- diff --git a/apidocs/org/apache/hadoop/hbase/client/class-use/Connection.html b/apidocs/org/apache/hadoop/hbase/client/class-use/Connection.html index 1a3939f..a66f9b9 100644 --- a/apidocs/org/apache/hadoop/hbase/client/class-use/Connection.html +++ b/apidocs/org/apache/hadoop/hbase/client/class-use/Connection.html @@ -219,6 +219,15 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods.</div> </td> </tr> <tr class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><span class="strong">LoadIncrementalHFiles.</span><code><strong><a href="../../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#loadHFileQueue(org.apache.hadoop.hbase.client.Table,%20org.apache.hadoop.hbase.client.Connection,%20java.util.Deque,%20org.apache.hadoop.hbase.util.Pair)">loadHFileQueue</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[][],byte[][]> startEndKeys)</code> +<div class="block">Used by the replication sink to load the hfiles from the source cluster.</div> +</td> +</tr> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem></code></td> <td class="colLast"><span class="strong">LoadIncrementalHFiles.</span><code><strong><a href="../../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#tryAtomicRegionLoad(org.apache.hadoop.hbase.client.Connection,%20org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.Collection)">tryAtomicRegionLoad</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, <a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName,
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/apidocs/org/apache/hadoop/hbase/client/class-use/Table.html ---------------------------------------------------------------------- diff --git a/apidocs/org/apache/hadoop/hbase/client/class-use/Table.html b/apidocs/org/apache/hadoop/hbase/client/class-use/Table.html index f06a9f1..d36ecd6 100644 --- a/apidocs/org/apache/hadoop/hbase/client/class-use/Table.html +++ b/apidocs/org/apache/hadoop/hbase/client/class-use/Table.html @@ -234,6 +234,26 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods.</div> </tr> <tr class="altColor"> <td class="colFirst"><code>void</code></td> +<td class="colLast"><span class="strong">LoadIncrementalHFiles.</span><code><strong><a href="../../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#loadHFileQueue(org.apache.hadoop.hbase.client.Table,%20org.apache.hadoop.hbase.client.Connection,%20java.util.Deque,%20org.apache.hadoop.hbase.util.Pair)">loadHFileQueue</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + <a href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[][],byte[][]> startEndKeys)</code> +<div class="block">Used by the replication sink to load the hfiles from the source cluster.</div> +</td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><span class="strong">LoadIncrementalHFiles.</span><code><strong><a href="../../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#prepareHFileQueue(org.apache.hadoop.fs.Path,%20org.apache.hadoop.hbase.client.Table,%20java.util.Deque,%20boolean)">prepareHFileQueue</a></strong>(org.apache.hadoop.fs.Path hfofDir, + <a href="../../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + boolean validateHFile)</code> +<div class="block">Prepare a collection of <code>LoadIncrementalHFiles.LoadQueueItem</code> from list of source hfiles contained in the + passed directory and validates whether the prepared queue has all the valid table column + families in it.</div> +</td> +</tr> +<tr class="altColor"> +<td class="colFirst"><code>void</code></td> <td class="colLast"><span class="strong">TableRecordReaderImpl.</span><code><strong><a href="../../../../../../org/apache/hadoop/hbase/mapreduce/TableRecordReaderImpl.html#setHTable(org.apache.hadoop.hbase.client.Table)">setHTable</a></strong>(<a href="../../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> htable)</code> <div class="block">Sets the HBase table.</div> </td> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/apidocs/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html ---------------------------------------------------------------------- diff --git a/apidocs/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html b/apidocs/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html index b4495d2..0dcd45b 100644 --- a/apidocs/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html +++ b/apidocs/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html @@ -101,7 +101,7 @@ <br> <pre>@InterfaceAudience.Public @InterfaceStability.Evolving -public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.89">ReplicationAdmin</a> +public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.88">ReplicationAdmin</a> extends <a href="http://docs.oracle.com/javase/7/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/7/docs/api/java/io/Closeable.html?is-external=true"; title="class or interface in java.io">Closeable</a></pre> <div class="block"><p> @@ -368,7 +368,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <ul class="blockList"> <li class="blockList"> <h4>TNAME</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.92">TNAME</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.91">TNAME</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.client.replication.ReplicationAdmin.TNAME">Constant Field Values</a></dd></dl> </li> </ul> @@ -378,7 +378,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <ul class="blockList"> <li class="blockList"> <h4>CFNAME</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.93">CFNAME</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.92">CFNAME</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.client.replication.ReplicationAdmin.CFNAME">Constant Field Values</a></dd></dl> </li> </ul> @@ -388,7 +388,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <ul class="blockList"> <li class="blockList"> <h4>REPLICATIONTYPE</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.97">REPLICATIONTYPE</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.96">REPLICATIONTYPE</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../../constant-values.html#org.apache.hadoop.hbase.client.replication.ReplicationAdmin.REPLICATIONTYPE">Constant Field Values</a></dd></dl> </li> </ul> @@ -398,7 +398,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <ul class="blockListLast"> <li class="blockList"> <h4>REPLICATIONGLOBAL</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.98">REPLICATIONGLOBAL</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.97">REPLICATIONGLOBAL</a></pre> </li> </ul> </li> @@ -415,7 +415,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <ul class="blockListLast"> <li class="blockList"> <h4>ReplicationAdmin</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.118">ReplicationAdmin</a>(org.apache.hadoop.conf.Configuration conf) +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.117">ReplicationAdmin</a>(org.apache.hadoop.conf.Configuration conf) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Constructor that creates a connection to the local ZooKeeper ensemble.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>conf</code> - Configuration to use</dd> @@ -439,7 +439,7 @@ implements <a href="http://docs.oracle.com/javase/7/docs/api/java/io/Closeable.h <li class="blockList"> <h4>addPeer</h4> <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.181">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.180">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> clusterKey) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block"><span class="strong">Deprecated.</span> <i>Use addPeer(String, ReplicationPeerConfig, Map) instead.</i></div> @@ -459,7 +459,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <li class="blockList"> <h4>addPeer</h4> <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.186">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.185">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> clusterKey, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCFs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> @@ -474,7 +474,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>addPeer</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.201">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.200">addPeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> peerConfig, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,? extends <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>> tableCfs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> @@ -493,7 +493,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>parseTableCFsFromConfig</h4> -<pre>public static <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.206">parseTableCFsFromConfig</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCFsConfig)</pre> +<pre>public static <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,<a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.205">parseTableCFsFromConfig</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCFsConfig)</pre> </li> </ul> <a name="removePeer(java.lang.String)"> @@ -502,7 +502,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>removePeer</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.280">removePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.279">removePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Removes a peer cluster and stops the replication to it.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - a short name that identifies the cluster</dd> @@ -516,7 +516,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>enablePeer</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.288">enablePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.287">enablePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Restart the replication stream to the specified peer.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - a short name that identifies the cluster</dd> @@ -530,7 +530,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>disablePeer</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.296">disablePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.295">disablePeer</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Stop the replication stream to the specified peer.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - a short name that identifies the cluster</dd> @@ -544,7 +544,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>getPeersCount</h4> -<pre>public int <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.304">getPeersCount</a>()</pre> +<pre>public int <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.303">getPeersCount</a>()</pre> <div class="block">Get the number of slave clusters the local cluster has.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>number of slave clusters</dd></dl> </li> @@ -556,7 +556,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <li class="blockList"> <h4>listPeers</h4> <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.314">listPeers</a>()</pre> +public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.313">listPeers</a>()</pre> <div class="block"><span class="strong">Deprecated.</span> <i>use <a href="../../../../../../org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#listPeerConfigs()"><code>listPeerConfigs()</code></a></i></div> <div class="block">Map of this cluster's peers for display.</div> <dl><dt><span class="strong">Returns:</span></dt><dd>A map of peer ids to peer cluster keys</dd></dl> @@ -568,7 +568,7 @@ public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html <ul class="blockList"> <li class="blockList"> <h4>listPeerConfigs</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.324">listPeerConfigs</a>()</pre> +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.323">listPeerConfigs</a>()</pre> </li> </ul> <a name="getPeerConfig(java.lang.String)"> @@ -577,7 +577,7 @@ public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html <ul class="blockList"> <li class="blockList"> <h4>getPeerConfig</h4> -<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.328">getPeerConfig</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html" title="class in org.apache.hadoop.hbase.replication">ReplicationPeerConfig</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.327">getPeerConfig</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></code></dd></dl> @@ -589,7 +589,7 @@ public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html <ul class="blockList"> <li class="blockList"> <h4>getPeerTableCFs</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.336">getPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public <a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.335">getPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Get the replicable table-cf config of the specified peer.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - a short name that identifies the cluster</dd> @@ -604,7 +604,7 @@ public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html <li class="blockList"> <h4>setPeerTableCFs</h4> <pre><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Deprecated.html?is-external=true"; title="class or interface in java.lang">@Deprecated</a> -public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.346">setPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.345">setPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCFs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block"><span class="strong">Deprecated.</span> <i>use <a href="../../../../../../org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#setPeerTableCFs(java.lang.String,%20java.util.Map)"><code>setPeerTableCFs(String, Map)</code></a></i></div> @@ -620,7 +620,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>appendPeerTableCFs</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.356">appendPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.355">appendPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCfs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Append the replicable table-cf config of the specified peer</div> @@ -635,7 +635,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>appendPeerTableCFs</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.366">appendPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.365">appendPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,? extends <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>> tableCfs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Append the replicable table-cf config of the specified peer</div> @@ -650,7 +650,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>removePeerTableCFs</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.406">removePeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.405">removePeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> tableCf) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Remove some table-cfs from table-cfs config of the specified peer</div> @@ -665,7 +665,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>removePeerTableCFs</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.416">removePeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.415">removePeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,? extends <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>> tableCfs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Remove some table-cfs from config of the specified peer</div> @@ -680,7 +680,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>setPeerTableCFs</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.463">setPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.462">setPeerTableCFs</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Map.html?is-external=true"; title="class or interface in java.util">Map</a><<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a>,? extends <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>>> tableCfs) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Set the replicable table-cf config of the specified peer</div> @@ -698,7 +698,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>getPeerState</h4> -<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.474">getPeerState</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) +<pre>public boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.473">getPeerState</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> id) throws <a href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationException.html" title="class in org.apache.hadoop.hbase.replication">ReplicationException</a></pre> <div class="block">Get the state of the specified peer cluster</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>id</code> - String format of the Short name that identifies the peer, @@ -714,7 +714,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>close</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.479">close</a>() +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.478">close</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><strong>Specified by:</strong></dt> @@ -731,7 +731,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>listReplicated</h4> -<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/util/HashMap.html?is-external=true"; title="class or interface in java.util">HashMap</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.500">listReplicated</a>() +<pre>public <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/util/HashMap.html?is-external=true"; title="class or interface in java.util">HashMap</a><<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>,<a href="http://docs.oracle.com/javase/7/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/replication/ReplicationAdmin.html#line.499">listReplicated</a>() throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Find all column families that are replicated from this cluster</div> <dl><dt><span class="strong">Returns:</span></dt><dd>the full list of the replicated column families of this cluster as: @@ -752,7 +752,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockList"> <li class="blockList"> <h4>enableTableRep</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.534">enableTableRep</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.533">enableTableRep</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Enable a table's replication switch.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>tableName</code> - name of the table</dd> @@ -766,7 +766,7 @@ public void <a href="../../../../../../src-html/org/apache/hadoop/hbas <ul class="blockListLast"> <li class="blockList"> <h4>disableTableRep</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.554">disableTableRep</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/client/replication/ReplicationAdmin.html#line.553">disableTableRep</a>(<a href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <div class="block">Disable a table's replication switch.</div> <dl><dt><span class="strong">Parameters:</span></dt><dd><code>tableName</code> - name of the table</dd> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f68717a0/apidocs/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html ---------------------------------------------------------------------- diff --git a/apidocs/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html b/apidocs/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html index c8b0609..2f0fd8e 100644 --- a/apidocs/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html +++ b/apidocs/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html @@ -106,7 +106,7 @@ <br> <pre>@InterfaceAudience.Public @InterfaceStability.Stable -public class <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.109">LoadIncrementalHFiles</a> +public class <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.110">LoadIncrementalHFiles</a> extends org.apache.hadoop.conf.Configured implements org.apache.hadoop.util.Tool</pre> <div class="block">Tool to load the output of HFileOutputFormat into an existing table.</div> @@ -216,21 +216,47 @@ implements org.apache.hadoop.util.Tool</pre> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#inferBoundaries(java.util.TreeMap)">inferBoundaries</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/TreeMap.html?is-external=true"; title="class or interface in java.util">TreeMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> bdryMap)</code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#loadHFileQueue(org.apache.hadoop.hbase.client.Table,%20org.apache.hadoop.hbase.client.Connection,%20java.util.Deque,%20org.apache.hadoop.hbase.util.Pair)">loadHFileQueue</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[][],byte[][]> startEndKeys)</code> +<div class="block">Used by the replication sink to load the hfiles from the source cluster.</div> +</td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>static void</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#main(java.lang.String[])">main</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args)</code> </td> </tr> +<tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#prepareHFileQueue(org.apache.hadoop.fs.Path,%20org.apache.hadoop.hbase.client.Table,%20java.util.Deque,%20boolean)">prepareHFileQueue</a></strong>(org.apache.hadoop.fs.Path hfofDir, + <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + boolean validateHFile)</code> +<div class="block">Prepare a collection of <code>LoadIncrementalHFiles.LoadQueueItem</code> from list of source hfiles contained in the + passed directory and validates whether the prepared queue has all the valid table column + families in it.</div> +</td> +</tr> <tr class="altColor"> <td class="colFirst"><code>int</code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#run(java.lang.String[])">run</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args)</code> </td> </tr> <tr class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#setBulkToken(java.lang.String)">setBulkToken</a></strong>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stagingDir)</code> +<div class="block">Called from replication sink, where it manages bulkToken(staging directory) by itself.</div> +</td> +</tr> +<tr class="altColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#splitStoreFile(org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem,%20org.apache.hadoop.hbase.client.Table,%20byte[],%20byte[])">splitStoreFile</a></strong>(org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem item, <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, byte[] startKey, byte[] splitKey)</code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem></code></td> <td class="colLast"><code><strong><a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#tryAtomicRegionLoad(org.apache.hadoop.hbase.client.Connection,%20org.apache.hadoop.hbase.TableName,%20byte[],%20java.util.Collection)">tryAtomicRegionLoad</a></strong>(<a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, @@ -281,7 +307,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>NAME</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.113">NAME</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.114">NAME</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.NAME">Constant Field Values</a></dd></dl> </li> </ul> @@ -291,7 +317,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>MAX_FILES_PER_REGION_PER_FAMILY</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.114">MAX_FILES_PER_REGION_PER_FAMILY</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.115">MAX_FILES_PER_REGION_PER_FAMILY</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.MAX_FILES_PER_REGION_PER_FAMILY">Constant Field Values</a></dd></dl> </li> </ul> @@ -301,7 +327,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockListLast"> <li class="blockList"> <h4>CREATE_TABLE_CONF_KEY</h4> -<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.117">CREATE_TABLE_CONF_KEY</a></pre> +<pre>public static final <a href="http://docs.oracle.com/javase/7/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/mapreduce/LoadIncrementalHFiles.html#line.118">CREATE_TABLE_CONF_KEY</a></pre> <dl><dt><span class="strong">See Also:</span></dt><dd><a href="../../../../../constant-values.html#org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.CREATE_TABLE_CONF_KEY">Constant Field Values</a></dd></dl> </li> </ul> @@ -319,7 +345,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockListLast"> <li class="blockList"> <h4>LoadIncrementalHFiles</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.131">LoadIncrementalHFiles</a>(org.apache.hadoop.conf.Configuration conf) +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.133">LoadIncrementalHFiles</a>(org.apache.hadoop.conf.Configuration conf) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></code></dd></dl> @@ -339,7 +365,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>doBulkLoad</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.299">doBulkLoad</a>(org.apache.hadoop.fs.Path hfofDir, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.303">doBulkLoad</a>(org.apache.hadoop.fs.Path hfofDir, org.apache.hadoop.hbase.client.HTable table) throws <a href="../../../../../org/apache/hadoop/hbase/TableNotFoundException.html" title="class in org.apache.hadoop.hbase">TableNotFoundException</a>, <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> @@ -358,7 +384,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>doBulkLoad</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.317">doBulkLoad</a>(org.apache.hadoop.fs.Path hfofDir, +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.320">doBulkLoad</a>(org.apache.hadoop.fs.Path hfofDir, <a href="../../../../../org/apache/hadoop/hbase/client/Admin.html" title="interface in org.apache.hadoop.hbase.client">Admin</a> admin, <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, <a href="../../../../../org/apache/hadoop/hbase/client/RegionLocator.html" title="interface in org.apache.hadoop.hbase.client">RegionLocator</a> regionLocator) @@ -373,13 +399,51 @@ implements org.apache.hadoop.util.Tool</pre> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> </li> </ul> +<a name="prepareHFileQueue(org.apache.hadoop.fs.Path, org.apache.hadoop.hbase.client.Table, java.util.Deque, boolean)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>prepareHFileQueue</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.430">prepareHFileQueue</a>(org.apache.hadoop.fs.Path hfofDir, + <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + boolean validateHFile) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> +<div class="block">Prepare a collection of <code>LoadIncrementalHFiles.LoadQueueItem</code> from list of source hfiles contained in the + passed directory and validates whether the prepared queue has all the valid table column + families in it.</div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>hfilesDir</code> - directory containing list of hfiles to be loaded into the table</dd><dd><code>table</code> - table to which hfiles should be loaded</dd><dd><code>queue</code> - queue which needs to be loaded into the table</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code> - If any I/O or network error occurred</dd></dl> +</li> +</ul> +<a name="loadHFileQueue(org.apache.hadoop.hbase.client.Table, org.apache.hadoop.hbase.client.Connection, java.util.Deque, org.apache.hadoop.hbase.util.Pair)"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>loadHFileQueue</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.485">loadHFileQueue</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, + <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, + <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, + <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[][],byte[][]> startEndKeys) + throws <a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> +<div class="block">Used by the replication sink to load the hfiles from the source cluster. It does the following, + 1. <a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#groupOrSplitPhase(org.apache.hadoop.hbase.client.Table,%20java.util.concurrent.ExecutorService,%20java.util.Deque,%20org.apache.hadoop.hbase.util.Pair)"><code>groupOrSplitPhase(Table, ExecutorService, Deque, Pair)</code></a> 2. + <a href="../../../../../org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#bulkLoadPhase(org.apache.hadoop.hbase.client.Table,%20org.apache.hadoop.hbase.client.Connection,%20java.util.concurrent.ExecutorService,%20java.util.Deque,%20com.google.common.collect.Multimap)"><code>bulkLoadPhase(Table, Connection, ExecutorService, Deque, Multimap)</code></a></div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>table</code> - Table to which these hfiles should be loaded to</dd><dd><code>conn</code> - Connection to use</dd><dd><code>queue</code> - <code>LoadIncrementalHFiles.LoadQueueItem</code> has hfiles yet to be loaded</dd><dd><code>startEndKeys</code> - starting and ending row keys of the region</dd> +<dt><span class="strong">Throws:</span></dt> +<dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd></dl> +</li> +</ul> <a name="bulkLoadPhase(org.apache.hadoop.hbase.client.Table, org.apache.hadoop.hbase.client.Connection, java.util.concurrent.ExecutorService, java.util.Deque, com.google.common.collect.Multimap)"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> <h4>bulkLoadPhase</h4> -<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.454">bulkLoadPhase</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, +<pre>protected void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.505">bulkLoadPhase</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, <a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html?is-external=true"; title="class or interface in java.util.concurrent">ExecutorService</a> pool, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Deque.html?is-external=true"; title="class or interface in java.util">Deque</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue, @@ -398,7 +462,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>splitStoreFile</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.577">splitStoreFile</a>(org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem item, +<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.628">splitStoreFile</a>(org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem item, <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, byte[] startKey, byte[] splitKey) @@ -413,7 +477,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>groupOrSplit</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.624">groupOrSplit</a>(com.google.common.collect.Multimap<<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a>,org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> regionGroups, +<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.675">groupOrSplit</a>(com.google.common.collect.Multimap<<a href="http://docs.oracle.com/javase/7/docs/api/java/nio/ByteBuffer.html?is-external=true"; title="class or interface in java.nio">ByteBuffer</a>,org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> regionGroups, org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem item, <a href="../../../../../org/apache/hadoop/hbase/client/Table.html" title="interface in org.apache.hadoop.hbase.client">Table</a> table, <a href="../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in org.apache.hadoop.hbase.util">Pair</a><byte[][],byte[][]> startEndKeys) @@ -434,7 +498,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>tryAtomicRegionLoad</h4> -<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.714">tryAtomicRegionLoad</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, +<pre>protected <a href="http://docs.oracle.com/javase/7/docs/api/java/util/List.html?is-external=true"; title="class or interface in java.util">List</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.769">tryAtomicRegionLoad</a>(<a href="../../../../../org/apache/hadoop/hbase/client/Connection.html" title="interface in org.apache.hadoop.hbase.client">Connection</a> conn, <a href="../../../../../org/apache/hadoop/hbase/TableName.html" title="class in org.apache.hadoop.hbase">TableName</a> tableName, byte[] first, <a href="http://docs.oracle.com/javase/7/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> lqis) @@ -459,7 +523,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>inferBoundaries</h4> -<pre>public static byte[][] <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.887">inferBoundaries</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/TreeMap.html?is-external=true"; title="class or interface in java.util">TreeMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> bdryMap)</pre> +<pre>public static byte[][] <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.946">inferBoundaries</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/util/TreeMap.html?is-external=true"; title="class or interface in java.util">TreeMap</a><byte[],<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Integer.html?is-external=true"; title="class or interface in java.lang">Integer</a>> bdryMap)</pre> </li> </ul> <a name="run(java.lang.String[])"> @@ -468,7 +532,7 @@ implements org.apache.hadoop.util.Tool</pre> <ul class="blockList"> <li class="blockList"> <h4>run</h4> -<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.963">run</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) +<pre>public int <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.1022">run</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><strong>Specified by:</strong></dt> @@ -480,15 +544,31 @@ implements org.apache.hadoop.util.Tool</pre> <a name="main(java.lang.String[])"> <!-- --> </a> -<ul class="blockListLast"> +<ul class="blockList"> <li class="blockList"> <h4>main</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.997">main</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.1056">main</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a>[] args) throws <a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl><dt><span class="strong">Throws:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/7/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></code></dd></dl> </li> </ul> +<a name="setBulkToken(java.lang.String)"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>setBulkToken</h4> +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.html#line.1071">setBulkToken</a>(<a href="http://docs.oracle.com/javase/7/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> stagingDir)</pre> +<div class="block">Called from replication sink, where it manages bulkToken(staging directory) by itself. This is + used only when <code>SecureBulkLoadEndpoint</code> is configured in hbase.coprocessor.region.classes + property. This directory is used as a temporary directory where all files are initially + copied/moved from user given directory, set all the required file permissions and then from + their it is finally loaded into a table. This should be set only when, one would like to manage + the staging directory by itself. Otherwise this tool will handle this by itself.</div> +<dl><dt><span class="strong">Parameters:</span></dt><dd><code>stagingDir</code> - staging directory path</dd></dl> +</li> +</ul> </li> </ul> </li>
