http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.AvailablePortChecker.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.AvailablePortChecker.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.AvailablePortChecker.html index 3b08b86..80483ee 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.AvailablePortChecker.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.AvailablePortChecker.html @@ -598,7 +598,7 @@ <span class="sourceLineNo">590</span> * Start a minidfscluster.<a name="line.590"></a> <span class="sourceLineNo">591</span> * @param servers How many DNs to start.<a name="line.591"></a> <span class="sourceLineNo">592</span> * @throws Exception<a name="line.592"></a> -<span class="sourceLineNo">593</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.593"></a> +<span class="sourceLineNo">593</span> * @see #shutdownMiniDFSCluster()<a name="line.593"></a> <span class="sourceLineNo">594</span> * @return The mini dfs cluster created.<a name="line.594"></a> <span class="sourceLineNo">595</span> */<a name="line.595"></a> <span class="sourceLineNo">596</span> public MiniDFSCluster startMiniDFSCluster(int servers) throws Exception {<a name="line.596"></a> @@ -613,7 +613,7 @@ <span class="sourceLineNo">605</span> * datanodes will have the same host name.<a name="line.605"></a> <span class="sourceLineNo">606</span> * @param hosts hostnames DNs to run on.<a name="line.606"></a> <span class="sourceLineNo">607</span> * @throws Exception<a name="line.607"></a> -<span class="sourceLineNo">608</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.608"></a> +<span class="sourceLineNo">608</span> * @see #shutdownMiniDFSCluster()<a name="line.608"></a> <span class="sourceLineNo">609</span> * @return The mini dfs cluster created.<a name="line.609"></a> <span class="sourceLineNo">610</span> */<a name="line.610"></a> <span class="sourceLineNo">611</span> public MiniDFSCluster startMiniDFSCluster(final String hosts[])<a name="line.611"></a> @@ -631,7 +631,7 @@ <span class="sourceLineNo">623</span> * @param servers How many DNs to start.<a name="line.623"></a> <span class="sourceLineNo">624</span> * @param hosts hostnames DNs to run on.<a name="line.624"></a> <span class="sourceLineNo">625</span> * @throws Exception<a name="line.625"></a> -<span class="sourceLineNo">626</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.626"></a> +<span class="sourceLineNo">626</span> * @see #shutdownMiniDFSCluster()<a name="line.626"></a> <span class="sourceLineNo">627</span> * @return The mini dfs cluster created.<a name="line.627"></a> <span class="sourceLineNo">628</span> */<a name="line.628"></a> <span class="sourceLineNo">629</span> public MiniDFSCluster startMiniDFSCluster(int servers, final String hosts[])<a name="line.629"></a> @@ -775,7 +775,7 @@ <span class="sourceLineNo">767</span> * Start up a minicluster of hbase, dfs, and zookeeper.<a name="line.767"></a> <span class="sourceLineNo">768</span> * @throws Exception<a name="line.768"></a> <span class="sourceLineNo">769</span> * @return Mini hbase cluster instance created.<a name="line.769"></a> -<span class="sourceLineNo">770</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.770"></a> +<span class="sourceLineNo">770</span> * @see #shutdownMiniDFSCluster()<a name="line.770"></a> <span class="sourceLineNo">771</span> */<a name="line.771"></a> <span class="sourceLineNo">772</span> public MiniHBaseCluster startMiniCluster() throws Exception {<a name="line.772"></a> <span class="sourceLineNo">773</span> return startMiniCluster(1, 1);<a name="line.773"></a> @@ -785,7 +785,7 @@ <span class="sourceLineNo">777</span> * Start up a minicluster of hbase, dfs, and zookeeper where WAL's walDir is created separately.<a name="line.777"></a> <span class="sourceLineNo">778</span> * @throws Exception<a name="line.778"></a> <span class="sourceLineNo">779</span> * @return Mini hbase cluster instance created.<a name="line.779"></a> -<span class="sourceLineNo">780</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.780"></a> +<span class="sourceLineNo">780</span> * @see #shutdownMiniDFSCluster()<a name="line.780"></a> <span class="sourceLineNo">781</span> */<a name="line.781"></a> <span class="sourceLineNo">782</span> public MiniHBaseCluster startMiniCluster(boolean withWALDir) throws Exception {<a name="line.782"></a> <span class="sourceLineNo">783</span> return startMiniCluster(1, 1, 1, null, null, null, false, withWALDir);<a name="line.783"></a> @@ -797,7 +797,7 @@ <span class="sourceLineNo">789</span> * (will overwrite if dir already exists)<a name="line.789"></a> <span class="sourceLineNo">790</span> * @throws Exception<a name="line.790"></a> <span class="sourceLineNo">791</span> * @return Mini hbase cluster instance created.<a name="line.791"></a> -<span class="sourceLineNo">792</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.792"></a> +<span class="sourceLineNo">792</span> * @see #shutdownMiniDFSCluster()<a name="line.792"></a> <span class="sourceLineNo">793</span> */<a name="line.793"></a> <span class="sourceLineNo">794</span> public MiniHBaseCluster startMiniCluster(final int numSlaves, boolean create)<a name="line.794"></a> <span class="sourceLineNo">795</span> throws Exception {<a name="line.795"></a> @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * hbase.regionserver.info.port is -1 (i.e. no ui per regionserver) otherwise<a name="line.806"></a> <span class="sourceLineNo">807</span> * bind errors.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @throws Exception<a name="line.808"></a> -<span class="sourceLineNo">809</span> * @see {@link #shutdownMiniCluster()}<a name="line.809"></a> +<span class="sourceLineNo">809</span> * @see #shutdownMiniCluster()<a name="line.809"></a> <span class="sourceLineNo">810</span> * @return Mini hbase cluster instance created.<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> public MiniHBaseCluster startMiniCluster(final int numSlaves)<a name="line.812"></a> @@ -831,7 +831,7 @@ <span class="sourceLineNo">823</span> * Start minicluster. Whether to create a new root or data dir path even if such a path<a name="line.823"></a> <span class="sourceLineNo">824</span> * has been created earlier is decided based on flag <code>create</code><a name="line.824"></a> <span class="sourceLineNo">825</span> * @throws Exception<a name="line.825"></a> -<span class="sourceLineNo">826</span> * @see {@link #shutdownMiniCluster()}<a name="line.826"></a> +<span class="sourceLineNo">826</span> * @see #shutdownMiniCluster()<a name="line.826"></a> <span class="sourceLineNo">827</span> * @return Mini hbase cluster instance created.<a name="line.827"></a> <span class="sourceLineNo">828</span> */<a name="line.828"></a> <span class="sourceLineNo">829</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.829"></a> @@ -843,7 +843,7 @@ <span class="sourceLineNo">835</span> /**<a name="line.835"></a> <span class="sourceLineNo">836</span> * start minicluster<a name="line.836"></a> <span class="sourceLineNo">837</span> * @throws Exception<a name="line.837"></a> -<span class="sourceLineNo">838</span> * @see {@link #shutdownMiniCluster()}<a name="line.838"></a> +<span class="sourceLineNo">838</span> * @see #shutdownMiniCluster()<a name="line.838"></a> <span class="sourceLineNo">839</span> * @return Mini hbase cluster instance created.<a name="line.839"></a> <span class="sourceLineNo">840</span> */<a name="line.840"></a> <span class="sourceLineNo">841</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.841"></a> @@ -880,7 +880,7 @@ <span class="sourceLineNo">872</span> * If you start MiniDFSCluster without host names,<a name="line.872"></a> <span class="sourceLineNo">873</span> * all instances of the datanodes will have the same host name.<a name="line.873"></a> <span class="sourceLineNo">874</span> * @throws Exception<a name="line.874"></a> -<span class="sourceLineNo">875</span> * @see {@link #shutdownMiniCluster()}<a name="line.875"></a> +<span class="sourceLineNo">875</span> * @see #shutdownMiniCluster()<a name="line.875"></a> <span class="sourceLineNo">876</span> * @return Mini hbase cluster instance created.<a name="line.876"></a> <span class="sourceLineNo">877</span> */<a name="line.877"></a> <span class="sourceLineNo">878</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.878"></a> @@ -922,7 +922,7 @@ <span class="sourceLineNo">914</span> * @param regionserverClass The class to use as HRegionServer, or null for<a name="line.914"></a> <span class="sourceLineNo">915</span> * default<a name="line.915"></a> <span class="sourceLineNo">916</span> * @throws Exception<a name="line.916"></a> -<span class="sourceLineNo">917</span> * @see {@link #shutdownMiniCluster()}<a name="line.917"></a> +<span class="sourceLineNo">917</span> * @see #shutdownMiniCluster()<a name="line.917"></a> <span class="sourceLineNo">918</span> * @return Mini hbase cluster instance created.<a name="line.918"></a> <span class="sourceLineNo">919</span> */<a name="line.919"></a> <span class="sourceLineNo">920</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.920"></a> @@ -1011,7 +1011,7 @@ <span class="sourceLineNo">1003</span> * @return Reference to the hbase mini hbase cluster.<a name="line.1003"></a> <span class="sourceLineNo">1004</span> * @throws IOException<a name="line.1004"></a> <span class="sourceLineNo">1005</span> * @throws InterruptedException<a name="line.1005"></a> -<span class="sourceLineNo">1006</span> * @see {@link #startMiniCluster()}<a name="line.1006"></a> +<span class="sourceLineNo">1006</span> * @see #startMiniCluster()<a name="line.1006"></a> <span class="sourceLineNo">1007</span> */<a name="line.1007"></a> <span class="sourceLineNo">1008</span> public MiniHBaseCluster startMiniHBaseCluster(final int numMasters,<a name="line.1008"></a> <span class="sourceLineNo">1009</span> final int numSlaves, List<Integer> rsPorts, Class<? extends HMaster> masterClass,<a name="line.1009"></a> @@ -1096,7 +1096,7 @@ <span class="sourceLineNo">1088</span> /**<a name="line.1088"></a> <span class="sourceLineNo">1089</span> * Stops mini hbase, zk, and hdfs clusters.<a name="line.1089"></a> <span class="sourceLineNo">1090</span> * @throws IOException<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> * @see {@link #startMiniCluster(int)}<a name="line.1091"></a> +<span class="sourceLineNo">1091</span> * @see #startMiniCluster(int)<a name="line.1091"></a> <span class="sourceLineNo">1092</span> */<a name="line.1092"></a> <span class="sourceLineNo">1093</span> public void shutdownMiniCluster() throws Exception {<a name="line.1093"></a> <span class="sourceLineNo">1094</span> LOG.info("Shutting down minicluster");<a name="line.1094"></a> @@ -1754,10 +1754,10 @@ <span class="sourceLineNo">1746</span><a name="line.1746"></a> <span class="sourceLineNo">1747</span> /**<a name="line.1747"></a> <span class="sourceLineNo">1748</span> * Create an HRegion that writes to the local tmp dirs<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> * @param desc<a name="line.1749"></a> -<span class="sourceLineNo">1750</span> * @param startKey<a name="line.1750"></a> -<span class="sourceLineNo">1751</span> * @param endKey<a name="line.1751"></a> -<span class="sourceLineNo">1752</span> * @return<a name="line.1752"></a> +<span class="sourceLineNo">1749</span> * @param desc a table descriptor indicating which table the region belongs to<a name="line.1749"></a> +<span class="sourceLineNo">1750</span> * @param startKey the start boundary of the region<a name="line.1750"></a> +<span class="sourceLineNo">1751</span> * @param endKey the end boundary of the region<a name="line.1751"></a> +<span class="sourceLineNo">1752</span> * @return a region that writes to local dir for testing<a name="line.1752"></a> <span class="sourceLineNo">1753</span> * @throws IOException<a name="line.1753"></a> <span class="sourceLineNo">1754</span> */<a name="line.1754"></a> <span class="sourceLineNo">1755</span> public HRegion createLocalHRegion(TableDescriptor desc, byte [] startKey,<a name="line.1755"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.html index 3b08b86..80483ee 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.PortAllocator.html @@ -598,7 +598,7 @@ <span class="sourceLineNo">590</span> * Start a minidfscluster.<a name="line.590"></a> <span class="sourceLineNo">591</span> * @param servers How many DNs to start.<a name="line.591"></a> <span class="sourceLineNo">592</span> * @throws Exception<a name="line.592"></a> -<span class="sourceLineNo">593</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.593"></a> +<span class="sourceLineNo">593</span> * @see #shutdownMiniDFSCluster()<a name="line.593"></a> <span class="sourceLineNo">594</span> * @return The mini dfs cluster created.<a name="line.594"></a> <span class="sourceLineNo">595</span> */<a name="line.595"></a> <span class="sourceLineNo">596</span> public MiniDFSCluster startMiniDFSCluster(int servers) throws Exception {<a name="line.596"></a> @@ -613,7 +613,7 @@ <span class="sourceLineNo">605</span> * datanodes will have the same host name.<a name="line.605"></a> <span class="sourceLineNo">606</span> * @param hosts hostnames DNs to run on.<a name="line.606"></a> <span class="sourceLineNo">607</span> * @throws Exception<a name="line.607"></a> -<span class="sourceLineNo">608</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.608"></a> +<span class="sourceLineNo">608</span> * @see #shutdownMiniDFSCluster()<a name="line.608"></a> <span class="sourceLineNo">609</span> * @return The mini dfs cluster created.<a name="line.609"></a> <span class="sourceLineNo">610</span> */<a name="line.610"></a> <span class="sourceLineNo">611</span> public MiniDFSCluster startMiniDFSCluster(final String hosts[])<a name="line.611"></a> @@ -631,7 +631,7 @@ <span class="sourceLineNo">623</span> * @param servers How many DNs to start.<a name="line.623"></a> <span class="sourceLineNo">624</span> * @param hosts hostnames DNs to run on.<a name="line.624"></a> <span class="sourceLineNo">625</span> * @throws Exception<a name="line.625"></a> -<span class="sourceLineNo">626</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.626"></a> +<span class="sourceLineNo">626</span> * @see #shutdownMiniDFSCluster()<a name="line.626"></a> <span class="sourceLineNo">627</span> * @return The mini dfs cluster created.<a name="line.627"></a> <span class="sourceLineNo">628</span> */<a name="line.628"></a> <span class="sourceLineNo">629</span> public MiniDFSCluster startMiniDFSCluster(int servers, final String hosts[])<a name="line.629"></a> @@ -775,7 +775,7 @@ <span class="sourceLineNo">767</span> * Start up a minicluster of hbase, dfs, and zookeeper.<a name="line.767"></a> <span class="sourceLineNo">768</span> * @throws Exception<a name="line.768"></a> <span class="sourceLineNo">769</span> * @return Mini hbase cluster instance created.<a name="line.769"></a> -<span class="sourceLineNo">770</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.770"></a> +<span class="sourceLineNo">770</span> * @see #shutdownMiniDFSCluster()<a name="line.770"></a> <span class="sourceLineNo">771</span> */<a name="line.771"></a> <span class="sourceLineNo">772</span> public MiniHBaseCluster startMiniCluster() throws Exception {<a name="line.772"></a> <span class="sourceLineNo">773</span> return startMiniCluster(1, 1);<a name="line.773"></a> @@ -785,7 +785,7 @@ <span class="sourceLineNo">777</span> * Start up a minicluster of hbase, dfs, and zookeeper where WAL's walDir is created separately.<a name="line.777"></a> <span class="sourceLineNo">778</span> * @throws Exception<a name="line.778"></a> <span class="sourceLineNo">779</span> * @return Mini hbase cluster instance created.<a name="line.779"></a> -<span class="sourceLineNo">780</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.780"></a> +<span class="sourceLineNo">780</span> * @see #shutdownMiniDFSCluster()<a name="line.780"></a> <span class="sourceLineNo">781</span> */<a name="line.781"></a> <span class="sourceLineNo">782</span> public MiniHBaseCluster startMiniCluster(boolean withWALDir) throws Exception {<a name="line.782"></a> <span class="sourceLineNo">783</span> return startMiniCluster(1, 1, 1, null, null, null, false, withWALDir);<a name="line.783"></a> @@ -797,7 +797,7 @@ <span class="sourceLineNo">789</span> * (will overwrite if dir already exists)<a name="line.789"></a> <span class="sourceLineNo">790</span> * @throws Exception<a name="line.790"></a> <span class="sourceLineNo">791</span> * @return Mini hbase cluster instance created.<a name="line.791"></a> -<span class="sourceLineNo">792</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.792"></a> +<span class="sourceLineNo">792</span> * @see #shutdownMiniDFSCluster()<a name="line.792"></a> <span class="sourceLineNo">793</span> */<a name="line.793"></a> <span class="sourceLineNo">794</span> public MiniHBaseCluster startMiniCluster(final int numSlaves, boolean create)<a name="line.794"></a> <span class="sourceLineNo">795</span> throws Exception {<a name="line.795"></a> @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * hbase.regionserver.info.port is -1 (i.e. no ui per regionserver) otherwise<a name="line.806"></a> <span class="sourceLineNo">807</span> * bind errors.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @throws Exception<a name="line.808"></a> -<span class="sourceLineNo">809</span> * @see {@link #shutdownMiniCluster()}<a name="line.809"></a> +<span class="sourceLineNo">809</span> * @see #shutdownMiniCluster()<a name="line.809"></a> <span class="sourceLineNo">810</span> * @return Mini hbase cluster instance created.<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> public MiniHBaseCluster startMiniCluster(final int numSlaves)<a name="line.812"></a> @@ -831,7 +831,7 @@ <span class="sourceLineNo">823</span> * Start minicluster. Whether to create a new root or data dir path even if such a path<a name="line.823"></a> <span class="sourceLineNo">824</span> * has been created earlier is decided based on flag <code>create</code><a name="line.824"></a> <span class="sourceLineNo">825</span> * @throws Exception<a name="line.825"></a> -<span class="sourceLineNo">826</span> * @see {@link #shutdownMiniCluster()}<a name="line.826"></a> +<span class="sourceLineNo">826</span> * @see #shutdownMiniCluster()<a name="line.826"></a> <span class="sourceLineNo">827</span> * @return Mini hbase cluster instance created.<a name="line.827"></a> <span class="sourceLineNo">828</span> */<a name="line.828"></a> <span class="sourceLineNo">829</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.829"></a> @@ -843,7 +843,7 @@ <span class="sourceLineNo">835</span> /**<a name="line.835"></a> <span class="sourceLineNo">836</span> * start minicluster<a name="line.836"></a> <span class="sourceLineNo">837</span> * @throws Exception<a name="line.837"></a> -<span class="sourceLineNo">838</span> * @see {@link #shutdownMiniCluster()}<a name="line.838"></a> +<span class="sourceLineNo">838</span> * @see #shutdownMiniCluster()<a name="line.838"></a> <span class="sourceLineNo">839</span> * @return Mini hbase cluster instance created.<a name="line.839"></a> <span class="sourceLineNo">840</span> */<a name="line.840"></a> <span class="sourceLineNo">841</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.841"></a> @@ -880,7 +880,7 @@ <span class="sourceLineNo">872</span> * If you start MiniDFSCluster without host names,<a name="line.872"></a> <span class="sourceLineNo">873</span> * all instances of the datanodes will have the same host name.<a name="line.873"></a> <span class="sourceLineNo">874</span> * @throws Exception<a name="line.874"></a> -<span class="sourceLineNo">875</span> * @see {@link #shutdownMiniCluster()}<a name="line.875"></a> +<span class="sourceLineNo">875</span> * @see #shutdownMiniCluster()<a name="line.875"></a> <span class="sourceLineNo">876</span> * @return Mini hbase cluster instance created.<a name="line.876"></a> <span class="sourceLineNo">877</span> */<a name="line.877"></a> <span class="sourceLineNo">878</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.878"></a> @@ -922,7 +922,7 @@ <span class="sourceLineNo">914</span> * @param regionserverClass The class to use as HRegionServer, or null for<a name="line.914"></a> <span class="sourceLineNo">915</span> * default<a name="line.915"></a> <span class="sourceLineNo">916</span> * @throws Exception<a name="line.916"></a> -<span class="sourceLineNo">917</span> * @see {@link #shutdownMiniCluster()}<a name="line.917"></a> +<span class="sourceLineNo">917</span> * @see #shutdownMiniCluster()<a name="line.917"></a> <span class="sourceLineNo">918</span> * @return Mini hbase cluster instance created.<a name="line.918"></a> <span class="sourceLineNo">919</span> */<a name="line.919"></a> <span class="sourceLineNo">920</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.920"></a> @@ -1011,7 +1011,7 @@ <span class="sourceLineNo">1003</span> * @return Reference to the hbase mini hbase cluster.<a name="line.1003"></a> <span class="sourceLineNo">1004</span> * @throws IOException<a name="line.1004"></a> <span class="sourceLineNo">1005</span> * @throws InterruptedException<a name="line.1005"></a> -<span class="sourceLineNo">1006</span> * @see {@link #startMiniCluster()}<a name="line.1006"></a> +<span class="sourceLineNo">1006</span> * @see #startMiniCluster()<a name="line.1006"></a> <span class="sourceLineNo">1007</span> */<a name="line.1007"></a> <span class="sourceLineNo">1008</span> public MiniHBaseCluster startMiniHBaseCluster(final int numMasters,<a name="line.1008"></a> <span class="sourceLineNo">1009</span> final int numSlaves, List<Integer> rsPorts, Class<? extends HMaster> masterClass,<a name="line.1009"></a> @@ -1096,7 +1096,7 @@ <span class="sourceLineNo">1088</span> /**<a name="line.1088"></a> <span class="sourceLineNo">1089</span> * Stops mini hbase, zk, and hdfs clusters.<a name="line.1089"></a> <span class="sourceLineNo">1090</span> * @throws IOException<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> * @see {@link #startMiniCluster(int)}<a name="line.1091"></a> +<span class="sourceLineNo">1091</span> * @see #startMiniCluster(int)<a name="line.1091"></a> <span class="sourceLineNo">1092</span> */<a name="line.1092"></a> <span class="sourceLineNo">1093</span> public void shutdownMiniCluster() throws Exception {<a name="line.1093"></a> <span class="sourceLineNo">1094</span> LOG.info("Shutting down minicluster");<a name="line.1094"></a> @@ -1754,10 +1754,10 @@ <span class="sourceLineNo">1746</span><a name="line.1746"></a> <span class="sourceLineNo">1747</span> /**<a name="line.1747"></a> <span class="sourceLineNo">1748</span> * Create an HRegion that writes to the local tmp dirs<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> * @param desc<a name="line.1749"></a> -<span class="sourceLineNo">1750</span> * @param startKey<a name="line.1750"></a> -<span class="sourceLineNo">1751</span> * @param endKey<a name="line.1751"></a> -<span class="sourceLineNo">1752</span> * @return<a name="line.1752"></a> +<span class="sourceLineNo">1749</span> * @param desc a table descriptor indicating which table the region belongs to<a name="line.1749"></a> +<span class="sourceLineNo">1750</span> * @param startKey the start boundary of the region<a name="line.1750"></a> +<span class="sourceLineNo">1751</span> * @param endKey the end boundary of the region<a name="line.1751"></a> +<span class="sourceLineNo">1752</span> * @return a region that writes to local dir for testing<a name="line.1752"></a> <span class="sourceLineNo">1753</span> * @throws IOException<a name="line.1753"></a> <span class="sourceLineNo">1754</span> */<a name="line.1754"></a> <span class="sourceLineNo">1755</span> public HRegion createLocalHRegion(TableDescriptor desc, byte [] startKey,<a name="line.1755"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.SeenRowTracker.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.SeenRowTracker.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.SeenRowTracker.html index 3b08b86..80483ee 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.SeenRowTracker.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.SeenRowTracker.html @@ -598,7 +598,7 @@ <span class="sourceLineNo">590</span> * Start a minidfscluster.<a name="line.590"></a> <span class="sourceLineNo">591</span> * @param servers How many DNs to start.<a name="line.591"></a> <span class="sourceLineNo">592</span> * @throws Exception<a name="line.592"></a> -<span class="sourceLineNo">593</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.593"></a> +<span class="sourceLineNo">593</span> * @see #shutdownMiniDFSCluster()<a name="line.593"></a> <span class="sourceLineNo">594</span> * @return The mini dfs cluster created.<a name="line.594"></a> <span class="sourceLineNo">595</span> */<a name="line.595"></a> <span class="sourceLineNo">596</span> public MiniDFSCluster startMiniDFSCluster(int servers) throws Exception {<a name="line.596"></a> @@ -613,7 +613,7 @@ <span class="sourceLineNo">605</span> * datanodes will have the same host name.<a name="line.605"></a> <span class="sourceLineNo">606</span> * @param hosts hostnames DNs to run on.<a name="line.606"></a> <span class="sourceLineNo">607</span> * @throws Exception<a name="line.607"></a> -<span class="sourceLineNo">608</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.608"></a> +<span class="sourceLineNo">608</span> * @see #shutdownMiniDFSCluster()<a name="line.608"></a> <span class="sourceLineNo">609</span> * @return The mini dfs cluster created.<a name="line.609"></a> <span class="sourceLineNo">610</span> */<a name="line.610"></a> <span class="sourceLineNo">611</span> public MiniDFSCluster startMiniDFSCluster(final String hosts[])<a name="line.611"></a> @@ -631,7 +631,7 @@ <span class="sourceLineNo">623</span> * @param servers How many DNs to start.<a name="line.623"></a> <span class="sourceLineNo">624</span> * @param hosts hostnames DNs to run on.<a name="line.624"></a> <span class="sourceLineNo">625</span> * @throws Exception<a name="line.625"></a> -<span class="sourceLineNo">626</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.626"></a> +<span class="sourceLineNo">626</span> * @see #shutdownMiniDFSCluster()<a name="line.626"></a> <span class="sourceLineNo">627</span> * @return The mini dfs cluster created.<a name="line.627"></a> <span class="sourceLineNo">628</span> */<a name="line.628"></a> <span class="sourceLineNo">629</span> public MiniDFSCluster startMiniDFSCluster(int servers, final String hosts[])<a name="line.629"></a> @@ -775,7 +775,7 @@ <span class="sourceLineNo">767</span> * Start up a minicluster of hbase, dfs, and zookeeper.<a name="line.767"></a> <span class="sourceLineNo">768</span> * @throws Exception<a name="line.768"></a> <span class="sourceLineNo">769</span> * @return Mini hbase cluster instance created.<a name="line.769"></a> -<span class="sourceLineNo">770</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.770"></a> +<span class="sourceLineNo">770</span> * @see #shutdownMiniDFSCluster()<a name="line.770"></a> <span class="sourceLineNo">771</span> */<a name="line.771"></a> <span class="sourceLineNo">772</span> public MiniHBaseCluster startMiniCluster() throws Exception {<a name="line.772"></a> <span class="sourceLineNo">773</span> return startMiniCluster(1, 1);<a name="line.773"></a> @@ -785,7 +785,7 @@ <span class="sourceLineNo">777</span> * Start up a minicluster of hbase, dfs, and zookeeper where WAL's walDir is created separately.<a name="line.777"></a> <span class="sourceLineNo">778</span> * @throws Exception<a name="line.778"></a> <span class="sourceLineNo">779</span> * @return Mini hbase cluster instance created.<a name="line.779"></a> -<span class="sourceLineNo">780</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.780"></a> +<span class="sourceLineNo">780</span> * @see #shutdownMiniDFSCluster()<a name="line.780"></a> <span class="sourceLineNo">781</span> */<a name="line.781"></a> <span class="sourceLineNo">782</span> public MiniHBaseCluster startMiniCluster(boolean withWALDir) throws Exception {<a name="line.782"></a> <span class="sourceLineNo">783</span> return startMiniCluster(1, 1, 1, null, null, null, false, withWALDir);<a name="line.783"></a> @@ -797,7 +797,7 @@ <span class="sourceLineNo">789</span> * (will overwrite if dir already exists)<a name="line.789"></a> <span class="sourceLineNo">790</span> * @throws Exception<a name="line.790"></a> <span class="sourceLineNo">791</span> * @return Mini hbase cluster instance created.<a name="line.791"></a> -<span class="sourceLineNo">792</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.792"></a> +<span class="sourceLineNo">792</span> * @see #shutdownMiniDFSCluster()<a name="line.792"></a> <span class="sourceLineNo">793</span> */<a name="line.793"></a> <span class="sourceLineNo">794</span> public MiniHBaseCluster startMiniCluster(final int numSlaves, boolean create)<a name="line.794"></a> <span class="sourceLineNo">795</span> throws Exception {<a name="line.795"></a> @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * hbase.regionserver.info.port is -1 (i.e. no ui per regionserver) otherwise<a name="line.806"></a> <span class="sourceLineNo">807</span> * bind errors.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @throws Exception<a name="line.808"></a> -<span class="sourceLineNo">809</span> * @see {@link #shutdownMiniCluster()}<a name="line.809"></a> +<span class="sourceLineNo">809</span> * @see #shutdownMiniCluster()<a name="line.809"></a> <span class="sourceLineNo">810</span> * @return Mini hbase cluster instance created.<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> public MiniHBaseCluster startMiniCluster(final int numSlaves)<a name="line.812"></a> @@ -831,7 +831,7 @@ <span class="sourceLineNo">823</span> * Start minicluster. Whether to create a new root or data dir path even if such a path<a name="line.823"></a> <span class="sourceLineNo">824</span> * has been created earlier is decided based on flag <code>create</code><a name="line.824"></a> <span class="sourceLineNo">825</span> * @throws Exception<a name="line.825"></a> -<span class="sourceLineNo">826</span> * @see {@link #shutdownMiniCluster()}<a name="line.826"></a> +<span class="sourceLineNo">826</span> * @see #shutdownMiniCluster()<a name="line.826"></a> <span class="sourceLineNo">827</span> * @return Mini hbase cluster instance created.<a name="line.827"></a> <span class="sourceLineNo">828</span> */<a name="line.828"></a> <span class="sourceLineNo">829</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.829"></a> @@ -843,7 +843,7 @@ <span class="sourceLineNo">835</span> /**<a name="line.835"></a> <span class="sourceLineNo">836</span> * start minicluster<a name="line.836"></a> <span class="sourceLineNo">837</span> * @throws Exception<a name="line.837"></a> -<span class="sourceLineNo">838</span> * @see {@link #shutdownMiniCluster()}<a name="line.838"></a> +<span class="sourceLineNo">838</span> * @see #shutdownMiniCluster()<a name="line.838"></a> <span class="sourceLineNo">839</span> * @return Mini hbase cluster instance created.<a name="line.839"></a> <span class="sourceLineNo">840</span> */<a name="line.840"></a> <span class="sourceLineNo">841</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.841"></a> @@ -880,7 +880,7 @@ <span class="sourceLineNo">872</span> * If you start MiniDFSCluster without host names,<a name="line.872"></a> <span class="sourceLineNo">873</span> * all instances of the datanodes will have the same host name.<a name="line.873"></a> <span class="sourceLineNo">874</span> * @throws Exception<a name="line.874"></a> -<span class="sourceLineNo">875</span> * @see {@link #shutdownMiniCluster()}<a name="line.875"></a> +<span class="sourceLineNo">875</span> * @see #shutdownMiniCluster()<a name="line.875"></a> <span class="sourceLineNo">876</span> * @return Mini hbase cluster instance created.<a name="line.876"></a> <span class="sourceLineNo">877</span> */<a name="line.877"></a> <span class="sourceLineNo">878</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.878"></a> @@ -922,7 +922,7 @@ <span class="sourceLineNo">914</span> * @param regionserverClass The class to use as HRegionServer, or null for<a name="line.914"></a> <span class="sourceLineNo">915</span> * default<a name="line.915"></a> <span class="sourceLineNo">916</span> * @throws Exception<a name="line.916"></a> -<span class="sourceLineNo">917</span> * @see {@link #shutdownMiniCluster()}<a name="line.917"></a> +<span class="sourceLineNo">917</span> * @see #shutdownMiniCluster()<a name="line.917"></a> <span class="sourceLineNo">918</span> * @return Mini hbase cluster instance created.<a name="line.918"></a> <span class="sourceLineNo">919</span> */<a name="line.919"></a> <span class="sourceLineNo">920</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.920"></a> @@ -1011,7 +1011,7 @@ <span class="sourceLineNo">1003</span> * @return Reference to the hbase mini hbase cluster.<a name="line.1003"></a> <span class="sourceLineNo">1004</span> * @throws IOException<a name="line.1004"></a> <span class="sourceLineNo">1005</span> * @throws InterruptedException<a name="line.1005"></a> -<span class="sourceLineNo">1006</span> * @see {@link #startMiniCluster()}<a name="line.1006"></a> +<span class="sourceLineNo">1006</span> * @see #startMiniCluster()<a name="line.1006"></a> <span class="sourceLineNo">1007</span> */<a name="line.1007"></a> <span class="sourceLineNo">1008</span> public MiniHBaseCluster startMiniHBaseCluster(final int numMasters,<a name="line.1008"></a> <span class="sourceLineNo">1009</span> final int numSlaves, List<Integer> rsPorts, Class<? extends HMaster> masterClass,<a name="line.1009"></a> @@ -1096,7 +1096,7 @@ <span class="sourceLineNo">1088</span> /**<a name="line.1088"></a> <span class="sourceLineNo">1089</span> * Stops mini hbase, zk, and hdfs clusters.<a name="line.1089"></a> <span class="sourceLineNo">1090</span> * @throws IOException<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> * @see {@link #startMiniCluster(int)}<a name="line.1091"></a> +<span class="sourceLineNo">1091</span> * @see #startMiniCluster(int)<a name="line.1091"></a> <span class="sourceLineNo">1092</span> */<a name="line.1092"></a> <span class="sourceLineNo">1093</span> public void shutdownMiniCluster() throws Exception {<a name="line.1093"></a> <span class="sourceLineNo">1094</span> LOG.info("Shutting down minicluster");<a name="line.1094"></a> @@ -1754,10 +1754,10 @@ <span class="sourceLineNo">1746</span><a name="line.1746"></a> <span class="sourceLineNo">1747</span> /**<a name="line.1747"></a> <span class="sourceLineNo">1748</span> * Create an HRegion that writes to the local tmp dirs<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> * @param desc<a name="line.1749"></a> -<span class="sourceLineNo">1750</span> * @param startKey<a name="line.1750"></a> -<span class="sourceLineNo">1751</span> * @param endKey<a name="line.1751"></a> -<span class="sourceLineNo">1752</span> * @return<a name="line.1752"></a> +<span class="sourceLineNo">1749</span> * @param desc a table descriptor indicating which table the region belongs to<a name="line.1749"></a> +<span class="sourceLineNo">1750</span> * @param startKey the start boundary of the region<a name="line.1750"></a> +<span class="sourceLineNo">1751</span> * @param endKey the end boundary of the region<a name="line.1751"></a> +<span class="sourceLineNo">1752</span> * @return a region that writes to local dir for testing<a name="line.1752"></a> <span class="sourceLineNo">1753</span> * @throws IOException<a name="line.1753"></a> <span class="sourceLineNo">1754</span> */<a name="line.1754"></a> <span class="sourceLineNo">1755</span> public HRegion createLocalHRegion(TableDescriptor desc, byte [] startKey,<a name="line.1755"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.html index 3b08b86..80483ee 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/HBaseTestingUtility.html @@ -598,7 +598,7 @@ <span class="sourceLineNo">590</span> * Start a minidfscluster.<a name="line.590"></a> <span class="sourceLineNo">591</span> * @param servers How many DNs to start.<a name="line.591"></a> <span class="sourceLineNo">592</span> * @throws Exception<a name="line.592"></a> -<span class="sourceLineNo">593</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.593"></a> +<span class="sourceLineNo">593</span> * @see #shutdownMiniDFSCluster()<a name="line.593"></a> <span class="sourceLineNo">594</span> * @return The mini dfs cluster created.<a name="line.594"></a> <span class="sourceLineNo">595</span> */<a name="line.595"></a> <span class="sourceLineNo">596</span> public MiniDFSCluster startMiniDFSCluster(int servers) throws Exception {<a name="line.596"></a> @@ -613,7 +613,7 @@ <span class="sourceLineNo">605</span> * datanodes will have the same host name.<a name="line.605"></a> <span class="sourceLineNo">606</span> * @param hosts hostnames DNs to run on.<a name="line.606"></a> <span class="sourceLineNo">607</span> * @throws Exception<a name="line.607"></a> -<span class="sourceLineNo">608</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.608"></a> +<span class="sourceLineNo">608</span> * @see #shutdownMiniDFSCluster()<a name="line.608"></a> <span class="sourceLineNo">609</span> * @return The mini dfs cluster created.<a name="line.609"></a> <span class="sourceLineNo">610</span> */<a name="line.610"></a> <span class="sourceLineNo">611</span> public MiniDFSCluster startMiniDFSCluster(final String hosts[])<a name="line.611"></a> @@ -631,7 +631,7 @@ <span class="sourceLineNo">623</span> * @param servers How many DNs to start.<a name="line.623"></a> <span class="sourceLineNo">624</span> * @param hosts hostnames DNs to run on.<a name="line.624"></a> <span class="sourceLineNo">625</span> * @throws Exception<a name="line.625"></a> -<span class="sourceLineNo">626</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.626"></a> +<span class="sourceLineNo">626</span> * @see #shutdownMiniDFSCluster()<a name="line.626"></a> <span class="sourceLineNo">627</span> * @return The mini dfs cluster created.<a name="line.627"></a> <span class="sourceLineNo">628</span> */<a name="line.628"></a> <span class="sourceLineNo">629</span> public MiniDFSCluster startMiniDFSCluster(int servers, final String hosts[])<a name="line.629"></a> @@ -775,7 +775,7 @@ <span class="sourceLineNo">767</span> * Start up a minicluster of hbase, dfs, and zookeeper.<a name="line.767"></a> <span class="sourceLineNo">768</span> * @throws Exception<a name="line.768"></a> <span class="sourceLineNo">769</span> * @return Mini hbase cluster instance created.<a name="line.769"></a> -<span class="sourceLineNo">770</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.770"></a> +<span class="sourceLineNo">770</span> * @see #shutdownMiniDFSCluster()<a name="line.770"></a> <span class="sourceLineNo">771</span> */<a name="line.771"></a> <span class="sourceLineNo">772</span> public MiniHBaseCluster startMiniCluster() throws Exception {<a name="line.772"></a> <span class="sourceLineNo">773</span> return startMiniCluster(1, 1);<a name="line.773"></a> @@ -785,7 +785,7 @@ <span class="sourceLineNo">777</span> * Start up a minicluster of hbase, dfs, and zookeeper where WAL's walDir is created separately.<a name="line.777"></a> <span class="sourceLineNo">778</span> * @throws Exception<a name="line.778"></a> <span class="sourceLineNo">779</span> * @return Mini hbase cluster instance created.<a name="line.779"></a> -<span class="sourceLineNo">780</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.780"></a> +<span class="sourceLineNo">780</span> * @see #shutdownMiniDFSCluster()<a name="line.780"></a> <span class="sourceLineNo">781</span> */<a name="line.781"></a> <span class="sourceLineNo">782</span> public MiniHBaseCluster startMiniCluster(boolean withWALDir) throws Exception {<a name="line.782"></a> <span class="sourceLineNo">783</span> return startMiniCluster(1, 1, 1, null, null, null, false, withWALDir);<a name="line.783"></a> @@ -797,7 +797,7 @@ <span class="sourceLineNo">789</span> * (will overwrite if dir already exists)<a name="line.789"></a> <span class="sourceLineNo">790</span> * @throws Exception<a name="line.790"></a> <span class="sourceLineNo">791</span> * @return Mini hbase cluster instance created.<a name="line.791"></a> -<span class="sourceLineNo">792</span> * @see {@link #shutdownMiniDFSCluster()}<a name="line.792"></a> +<span class="sourceLineNo">792</span> * @see #shutdownMiniDFSCluster()<a name="line.792"></a> <span class="sourceLineNo">793</span> */<a name="line.793"></a> <span class="sourceLineNo">794</span> public MiniHBaseCluster startMiniCluster(final int numSlaves, boolean create)<a name="line.794"></a> <span class="sourceLineNo">795</span> throws Exception {<a name="line.795"></a> @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * hbase.regionserver.info.port is -1 (i.e. no ui per regionserver) otherwise<a name="line.806"></a> <span class="sourceLineNo">807</span> * bind errors.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @throws Exception<a name="line.808"></a> -<span class="sourceLineNo">809</span> * @see {@link #shutdownMiniCluster()}<a name="line.809"></a> +<span class="sourceLineNo">809</span> * @see #shutdownMiniCluster()<a name="line.809"></a> <span class="sourceLineNo">810</span> * @return Mini hbase cluster instance created.<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> public MiniHBaseCluster startMiniCluster(final int numSlaves)<a name="line.812"></a> @@ -831,7 +831,7 @@ <span class="sourceLineNo">823</span> * Start minicluster. Whether to create a new root or data dir path even if such a path<a name="line.823"></a> <span class="sourceLineNo">824</span> * has been created earlier is decided based on flag <code>create</code><a name="line.824"></a> <span class="sourceLineNo">825</span> * @throws Exception<a name="line.825"></a> -<span class="sourceLineNo">826</span> * @see {@link #shutdownMiniCluster()}<a name="line.826"></a> +<span class="sourceLineNo">826</span> * @see #shutdownMiniCluster()<a name="line.826"></a> <span class="sourceLineNo">827</span> * @return Mini hbase cluster instance created.<a name="line.827"></a> <span class="sourceLineNo">828</span> */<a name="line.828"></a> <span class="sourceLineNo">829</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.829"></a> @@ -843,7 +843,7 @@ <span class="sourceLineNo">835</span> /**<a name="line.835"></a> <span class="sourceLineNo">836</span> * start minicluster<a name="line.836"></a> <span class="sourceLineNo">837</span> * @throws Exception<a name="line.837"></a> -<span class="sourceLineNo">838</span> * @see {@link #shutdownMiniCluster()}<a name="line.838"></a> +<span class="sourceLineNo">838</span> * @see #shutdownMiniCluster()<a name="line.838"></a> <span class="sourceLineNo">839</span> * @return Mini hbase cluster instance created.<a name="line.839"></a> <span class="sourceLineNo">840</span> */<a name="line.840"></a> <span class="sourceLineNo">841</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.841"></a> @@ -880,7 +880,7 @@ <span class="sourceLineNo">872</span> * If you start MiniDFSCluster without host names,<a name="line.872"></a> <span class="sourceLineNo">873</span> * all instances of the datanodes will have the same host name.<a name="line.873"></a> <span class="sourceLineNo">874</span> * @throws Exception<a name="line.874"></a> -<span class="sourceLineNo">875</span> * @see {@link #shutdownMiniCluster()}<a name="line.875"></a> +<span class="sourceLineNo">875</span> * @see #shutdownMiniCluster()<a name="line.875"></a> <span class="sourceLineNo">876</span> * @return Mini hbase cluster instance created.<a name="line.876"></a> <span class="sourceLineNo">877</span> */<a name="line.877"></a> <span class="sourceLineNo">878</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.878"></a> @@ -922,7 +922,7 @@ <span class="sourceLineNo">914</span> * @param regionserverClass The class to use as HRegionServer, or null for<a name="line.914"></a> <span class="sourceLineNo">915</span> * default<a name="line.915"></a> <span class="sourceLineNo">916</span> * @throws Exception<a name="line.916"></a> -<span class="sourceLineNo">917</span> * @see {@link #shutdownMiniCluster()}<a name="line.917"></a> +<span class="sourceLineNo">917</span> * @see #shutdownMiniCluster()<a name="line.917"></a> <span class="sourceLineNo">918</span> * @return Mini hbase cluster instance created.<a name="line.918"></a> <span class="sourceLineNo">919</span> */<a name="line.919"></a> <span class="sourceLineNo">920</span> public MiniHBaseCluster startMiniCluster(final int numMasters,<a name="line.920"></a> @@ -1011,7 +1011,7 @@ <span class="sourceLineNo">1003</span> * @return Reference to the hbase mini hbase cluster.<a name="line.1003"></a> <span class="sourceLineNo">1004</span> * @throws IOException<a name="line.1004"></a> <span class="sourceLineNo">1005</span> * @throws InterruptedException<a name="line.1005"></a> -<span class="sourceLineNo">1006</span> * @see {@link #startMiniCluster()}<a name="line.1006"></a> +<span class="sourceLineNo">1006</span> * @see #startMiniCluster()<a name="line.1006"></a> <span class="sourceLineNo">1007</span> */<a name="line.1007"></a> <span class="sourceLineNo">1008</span> public MiniHBaseCluster startMiniHBaseCluster(final int numMasters,<a name="line.1008"></a> <span class="sourceLineNo">1009</span> final int numSlaves, List<Integer> rsPorts, Class<? extends HMaster> masterClass,<a name="line.1009"></a> @@ -1096,7 +1096,7 @@ <span class="sourceLineNo">1088</span> /**<a name="line.1088"></a> <span class="sourceLineNo">1089</span> * Stops mini hbase, zk, and hdfs clusters.<a name="line.1089"></a> <span class="sourceLineNo">1090</span> * @throws IOException<a name="line.1090"></a> -<span class="sourceLineNo">1091</span> * @see {@link #startMiniCluster(int)}<a name="line.1091"></a> +<span class="sourceLineNo">1091</span> * @see #startMiniCluster(int)<a name="line.1091"></a> <span class="sourceLineNo">1092</span> */<a name="line.1092"></a> <span class="sourceLineNo">1093</span> public void shutdownMiniCluster() throws Exception {<a name="line.1093"></a> <span class="sourceLineNo">1094</span> LOG.info("Shutting down minicluster");<a name="line.1094"></a> @@ -1754,10 +1754,10 @@ <span class="sourceLineNo">1746</span><a name="line.1746"></a> <span class="sourceLineNo">1747</span> /**<a name="line.1747"></a> <span class="sourceLineNo">1748</span> * Create an HRegion that writes to the local tmp dirs<a name="line.1748"></a> -<span class="sourceLineNo">1749</span> * @param desc<a name="line.1749"></a> -<span class="sourceLineNo">1750</span> * @param startKey<a name="line.1750"></a> -<span class="sourceLineNo">1751</span> * @param endKey<a name="line.1751"></a> -<span class="sourceLineNo">1752</span> * @return<a name="line.1752"></a> +<span class="sourceLineNo">1749</span> * @param desc a table descriptor indicating which table the region belongs to<a name="line.1749"></a> +<span class="sourceLineNo">1750</span> * @param startKey the start boundary of the region<a name="line.1750"></a> +<span class="sourceLineNo">1751</span> * @param endKey the end boundary of the region<a name="line.1751"></a> +<span class="sourceLineNo">1752</span> * @return a region that writes to local dir for testing<a name="line.1752"></a> <span class="sourceLineNo">1753</span> * @throws IOException<a name="line.1753"></a> <span class="sourceLineNo">1754</span> */<a name="line.1754"></a> <span class="sourceLineNo">1755</span> public HRegion createLocalHRegion(TableDescriptor desc, byte [] startKey,<a name="line.1755"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestBase.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestBase.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestBase.html index 47c5bf5..93d5537 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestBase.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestBase.html @@ -46,10 +46,10 @@ <span class="sourceLineNo">038</span><a name="line.38"></a> <span class="sourceLineNo">039</span>/**<a name="line.39"></a> <span class="sourceLineNo">040</span> * Base class for HBase integration tests that want to use the Chaos Monkey.<a name="line.40"></a> -<span class="sourceLineNo">041</span> * Usage: bin/hbase <sub_class_of_IntegrationTestBase> <options><a name="line.41"></a> +<span class="sourceLineNo">041</span> * Usage: bin/hbase &lt;sub_class_of_IntegrationTestBase> &lt;options><a name="line.41"></a> <span class="sourceLineNo">042</span> * Options: -h,--help Show usage<a name="line.42"></a> -<span class="sourceLineNo">043</span> * -m,--monkey <arg> Which chaos monkey to run<a name="line.43"></a> -<span class="sourceLineNo">044</span> * -monkeyProps <arg> The properties file for specifying chaos monkey properties.<a name="line.44"></a> +<span class="sourceLineNo">043</span> * -m,--monkey &lt;arg> Which chaos monkey to run<a name="line.43"></a> +<span class="sourceLineNo">044</span> * -monkeyProps &lt;arg> The properties file for specifying chaos monkey properties.<a name="line.44"></a> <span class="sourceLineNo">045</span> * -ncc Option to not clean up the cluster at the end.<a name="line.45"></a> <span class="sourceLineNo">046</span> */<a name="line.46"></a> <span class="sourceLineNo">047</span>public abstract class IntegrationTestBase extends AbstractHBaseTool {<a name="line.47"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater.html index 7249a34..357c635 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedUpdater.html @@ -58,7 +58,7 @@ <span class="sourceLineNo">050</span> * with the replication of the edits before read_delay_ms to the given region replica id so that<a name="line.50"></a> <span class="sourceLineNo">051</span> * the read and verify will not fail.<a name="line.51"></a> <span class="sourceLineNo">052</span> *<a name="line.52"></a> -<span class="sourceLineNo">053</span> * The job will run for <b>at least<b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> +<span class="sourceLineNo">053</span> * The job will run for <b>at least</b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> <span class="sourceLineNo">054</span> * writer and reader workload followed by a concurrent updater and reader workload for<a name="line.54"></a> <span class="sourceLineNo">055</span> * num_keys_per_server.<a name="line.55"></a> <span class="sourceLineNo">056</span> * <p><a name="line.56"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter.html index 7249a34..357c635 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.DelayingMultiThreadedWriter.html @@ -58,7 +58,7 @@ <span class="sourceLineNo">050</span> * with the replication of the edits before read_delay_ms to the given region replica id so that<a name="line.50"></a> <span class="sourceLineNo">051</span> * the read and verify will not fail.<a name="line.51"></a> <span class="sourceLineNo">052</span> *<a name="line.52"></a> -<span class="sourceLineNo">053</span> * The job will run for <b>at least<b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> +<span class="sourceLineNo">053</span> * The job will run for <b>at least</b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> <span class="sourceLineNo">054</span> * writer and reader workload followed by a concurrent updater and reader workload for<a name="line.54"></a> <span class="sourceLineNo">055</span> * num_keys_per_server.<a name="line.55"></a> <span class="sourceLineNo">056</span> * <p><a name="line.56"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.html index 7249a34..357c635 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/IntegrationTestRegionReplicaReplication.html @@ -58,7 +58,7 @@ <span class="sourceLineNo">050</span> * with the replication of the edits before read_delay_ms to the given region replica id so that<a name="line.50"></a> <span class="sourceLineNo">051</span> * the read and verify will not fail.<a name="line.51"></a> <span class="sourceLineNo">052</span> *<a name="line.52"></a> -<span class="sourceLineNo">053</span> * The job will run for <b>at least<b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> +<span class="sourceLineNo">053</span> * The job will run for <b>at least</b> given runtime (default 10min) by running a concurrent<a name="line.53"></a> <span class="sourceLineNo">054</span> * writer and reader workload followed by a concurrent updater and reader workload for<a name="line.54"></a> <span class="sourceLineNo">055</span> * num_keys_per_server.<a name="line.55"></a> <span class="sourceLineNo">056</span> * <p><a name="line.56"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.RepeatingTestThread.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.RepeatingTestThread.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.RepeatingTestThread.html index 6958746..fd38f4b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.RepeatingTestThread.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.RepeatingTestThread.html @@ -171,37 +171,36 @@ <span class="sourceLineNo">163</span> * Verify that no assertions have failed inside a future.<a name="line.163"></a> <span class="sourceLineNo">164</span> * Used for unit tests that spawn threads. E.g.,<a name="line.164"></a> <span class="sourceLineNo">165</span> * <p><a name="line.165"></a> -<span class="sourceLineNo">166</span> * <code><a name="line.166"></a> -<span class="sourceLineNo">167</span> * List<Future<Void>> results = Lists.newArrayList();<a name="line.167"></a> -<span class="sourceLineNo">168</span> * Future<Void> f = executor.submit(new Callable<Void> {<a name="line.168"></a> +<span class="sourceLineNo">166</span> * <pre><a name="line.166"></a> +<span class="sourceLineNo">167</span> * List&lt;Future&lt;Void>> results = Lists.newArrayList();<a name="line.167"></a> +<span class="sourceLineNo">168</span> * Future&lt;Void> f = executor.submit(new Callable&lt;Void> {<a name="line.168"></a> <span class="sourceLineNo">169</span> * public Void call() {<a name="line.169"></a> <span class="sourceLineNo">170</span> * assertTrue(someMethod());<a name="line.170"></a> <span class="sourceLineNo">171</span> * }<a name="line.171"></a> <span class="sourceLineNo">172</span> * });<a name="line.172"></a> <span class="sourceLineNo">173</span> * results.add(f);<a name="line.173"></a> <span class="sourceLineNo">174</span> * assertOnFutures(results);<a name="line.174"></a> -<span class="sourceLineNo">175</span> * </code><a name="line.175"></a> +<span class="sourceLineNo">175</span> * </pre><a name="line.175"></a> <span class="sourceLineNo">176</span> * @param threadResults A list of futures<a name="line.176"></a> -<span class="sourceLineNo">177</span> * @param <T><a name="line.177"></a> -<span class="sourceLineNo">178</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.178"></a> -<span class="sourceLineNo">179</span> * from one of the futures<a name="line.179"></a> -<span class="sourceLineNo">180</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.180"></a> -<span class="sourceLineNo">181</span> * occurs inside any of the futures<a name="line.181"></a> -<span class="sourceLineNo">182</span> */<a name="line.182"></a> -<span class="sourceLineNo">183</span> public static <T> void assertOnFutures(List<Future<T>> threadResults)<a name="line.183"></a> -<span class="sourceLineNo">184</span> throws InterruptedException, ExecutionException {<a name="line.184"></a> -<span class="sourceLineNo">185</span> for (Future<T> threadResult : threadResults) {<a name="line.185"></a> -<span class="sourceLineNo">186</span> try {<a name="line.186"></a> -<span class="sourceLineNo">187</span> threadResult.get();<a name="line.187"></a> -<span class="sourceLineNo">188</span> } catch (ExecutionException e) {<a name="line.188"></a> -<span class="sourceLineNo">189</span> if (e.getCause() instanceof AssertionError) {<a name="line.189"></a> -<span class="sourceLineNo">190</span> throw (AssertionError) e.getCause();<a name="line.190"></a> -<span class="sourceLineNo">191</span> }<a name="line.191"></a> -<span class="sourceLineNo">192</span> throw e;<a name="line.192"></a> -<span class="sourceLineNo">193</span> }<a name="line.193"></a> -<span class="sourceLineNo">194</span> }<a name="line.194"></a> -<span class="sourceLineNo">195</span> }<a name="line.195"></a> -<span class="sourceLineNo">196</span>}<a name="line.196"></a> +<span class="sourceLineNo">177</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.177"></a> +<span class="sourceLineNo">178</span> * from one of the futures<a name="line.178"></a> +<span class="sourceLineNo">179</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.179"></a> +<span class="sourceLineNo">180</span> * occurs inside any of the futures<a name="line.180"></a> +<span class="sourceLineNo">181</span> */<a name="line.181"></a> +<span class="sourceLineNo">182</span> public static void assertOnFutures(List<Future<?>> threadResults)<a name="line.182"></a> +<span class="sourceLineNo">183</span> throws InterruptedException, ExecutionException {<a name="line.183"></a> +<span class="sourceLineNo">184</span> for (Future<?> threadResult : threadResults) {<a name="line.184"></a> +<span class="sourceLineNo">185</span> try {<a name="line.185"></a> +<span class="sourceLineNo">186</span> threadResult.get();<a name="line.186"></a> +<span class="sourceLineNo">187</span> } catch (ExecutionException e) {<a name="line.187"></a> +<span class="sourceLineNo">188</span> if (e.getCause() instanceof AssertionError) {<a name="line.188"></a> +<span class="sourceLineNo">189</span> throw (AssertionError) e.getCause();<a name="line.189"></a> +<span class="sourceLineNo">190</span> }<a name="line.190"></a> +<span class="sourceLineNo">191</span> throw e;<a name="line.191"></a> +<span class="sourceLineNo">192</span> }<a name="line.192"></a> +<span class="sourceLineNo">193</span> }<a name="line.193"></a> +<span class="sourceLineNo">194</span> }<a name="line.194"></a> +<span class="sourceLineNo">195</span>}<a name="line.195"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestContext.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestContext.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestContext.html index 6958746..fd38f4b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestContext.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestContext.html @@ -171,37 +171,36 @@ <span class="sourceLineNo">163</span> * Verify that no assertions have failed inside a future.<a name="line.163"></a> <span class="sourceLineNo">164</span> * Used for unit tests that spawn threads. E.g.,<a name="line.164"></a> <span class="sourceLineNo">165</span> * <p><a name="line.165"></a> -<span class="sourceLineNo">166</span> * <code><a name="line.166"></a> -<span class="sourceLineNo">167</span> * List<Future<Void>> results = Lists.newArrayList();<a name="line.167"></a> -<span class="sourceLineNo">168</span> * Future<Void> f = executor.submit(new Callable<Void> {<a name="line.168"></a> +<span class="sourceLineNo">166</span> * <pre><a name="line.166"></a> +<span class="sourceLineNo">167</span> * List&lt;Future&lt;Void>> results = Lists.newArrayList();<a name="line.167"></a> +<span class="sourceLineNo">168</span> * Future&lt;Void> f = executor.submit(new Callable&lt;Void> {<a name="line.168"></a> <span class="sourceLineNo">169</span> * public Void call() {<a name="line.169"></a> <span class="sourceLineNo">170</span> * assertTrue(someMethod());<a name="line.170"></a> <span class="sourceLineNo">171</span> * }<a name="line.171"></a> <span class="sourceLineNo">172</span> * });<a name="line.172"></a> <span class="sourceLineNo">173</span> * results.add(f);<a name="line.173"></a> <span class="sourceLineNo">174</span> * assertOnFutures(results);<a name="line.174"></a> -<span class="sourceLineNo">175</span> * </code><a name="line.175"></a> +<span class="sourceLineNo">175</span> * </pre><a name="line.175"></a> <span class="sourceLineNo">176</span> * @param threadResults A list of futures<a name="line.176"></a> -<span class="sourceLineNo">177</span> * @param <T><a name="line.177"></a> -<span class="sourceLineNo">178</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.178"></a> -<span class="sourceLineNo">179</span> * from one of the futures<a name="line.179"></a> -<span class="sourceLineNo">180</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.180"></a> -<span class="sourceLineNo">181</span> * occurs inside any of the futures<a name="line.181"></a> -<span class="sourceLineNo">182</span> */<a name="line.182"></a> -<span class="sourceLineNo">183</span> public static <T> void assertOnFutures(List<Future<T>> threadResults)<a name="line.183"></a> -<span class="sourceLineNo">184</span> throws InterruptedException, ExecutionException {<a name="line.184"></a> -<span class="sourceLineNo">185</span> for (Future<T> threadResult : threadResults) {<a name="line.185"></a> -<span class="sourceLineNo">186</span> try {<a name="line.186"></a> -<span class="sourceLineNo">187</span> threadResult.get();<a name="line.187"></a> -<span class="sourceLineNo">188</span> } catch (ExecutionException e) {<a name="line.188"></a> -<span class="sourceLineNo">189</span> if (e.getCause() instanceof AssertionError) {<a name="line.189"></a> -<span class="sourceLineNo">190</span> throw (AssertionError) e.getCause();<a name="line.190"></a> -<span class="sourceLineNo">191</span> }<a name="line.191"></a> -<span class="sourceLineNo">192</span> throw e;<a name="line.192"></a> -<span class="sourceLineNo">193</span> }<a name="line.193"></a> -<span class="sourceLineNo">194</span> }<a name="line.194"></a> -<span class="sourceLineNo">195</span> }<a name="line.195"></a> -<span class="sourceLineNo">196</span>}<a name="line.196"></a> +<span class="sourceLineNo">177</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.177"></a> +<span class="sourceLineNo">178</span> * from one of the futures<a name="line.178"></a> +<span class="sourceLineNo">179</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.179"></a> +<span class="sourceLineNo">180</span> * occurs inside any of the futures<a name="line.180"></a> +<span class="sourceLineNo">181</span> */<a name="line.181"></a> +<span class="sourceLineNo">182</span> public static void assertOnFutures(List<Future<?>> threadResults)<a name="line.182"></a> +<span class="sourceLineNo">183</span> throws InterruptedException, ExecutionException {<a name="line.183"></a> +<span class="sourceLineNo">184</span> for (Future<?> threadResult : threadResults) {<a name="line.184"></a> +<span class="sourceLineNo">185</span> try {<a name="line.185"></a> +<span class="sourceLineNo">186</span> threadResult.get();<a name="line.186"></a> +<span class="sourceLineNo">187</span> } catch (ExecutionException e) {<a name="line.187"></a> +<span class="sourceLineNo">188</span> if (e.getCause() instanceof AssertionError) {<a name="line.188"></a> +<span class="sourceLineNo">189</span> throw (AssertionError) e.getCause();<a name="line.189"></a> +<span class="sourceLineNo">190</span> }<a name="line.190"></a> +<span class="sourceLineNo">191</span> throw e;<a name="line.191"></a> +<span class="sourceLineNo">192</span> }<a name="line.192"></a> +<span class="sourceLineNo">193</span> }<a name="line.193"></a> +<span class="sourceLineNo">194</span> }<a name="line.194"></a> +<span class="sourceLineNo">195</span>}<a name="line.195"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestThread.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestThread.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestThread.html index 6958746..fd38f4b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestThread.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.TestThread.html @@ -171,37 +171,36 @@ <span class="sourceLineNo">163</span> * Verify that no assertions have failed inside a future.<a name="line.163"></a> <span class="sourceLineNo">164</span> * Used for unit tests that spawn threads. E.g.,<a name="line.164"></a> <span class="sourceLineNo">165</span> * <p><a name="line.165"></a> -<span class="sourceLineNo">166</span> * <code><a name="line.166"></a> -<span class="sourceLineNo">167</span> * List<Future<Void>> results = Lists.newArrayList();<a name="line.167"></a> -<span class="sourceLineNo">168</span> * Future<Void> f = executor.submit(new Callable<Void> {<a name="line.168"></a> +<span class="sourceLineNo">166</span> * <pre><a name="line.166"></a> +<span class="sourceLineNo">167</span> * List&lt;Future&lt;Void>> results = Lists.newArrayList();<a name="line.167"></a> +<span class="sourceLineNo">168</span> * Future&lt;Void> f = executor.submit(new Callable&lt;Void> {<a name="line.168"></a> <span class="sourceLineNo">169</span> * public Void call() {<a name="line.169"></a> <span class="sourceLineNo">170</span> * assertTrue(someMethod());<a name="line.170"></a> <span class="sourceLineNo">171</span> * }<a name="line.171"></a> <span class="sourceLineNo">172</span> * });<a name="line.172"></a> <span class="sourceLineNo">173</span> * results.add(f);<a name="line.173"></a> <span class="sourceLineNo">174</span> * assertOnFutures(results);<a name="line.174"></a> -<span class="sourceLineNo">175</span> * </code><a name="line.175"></a> +<span class="sourceLineNo">175</span> * </pre><a name="line.175"></a> <span class="sourceLineNo">176</span> * @param threadResults A list of futures<a name="line.176"></a> -<span class="sourceLineNo">177</span> * @param <T><a name="line.177"></a> -<span class="sourceLineNo">178</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.178"></a> -<span class="sourceLineNo">179</span> * from one of the futures<a name="line.179"></a> -<span class="sourceLineNo">180</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.180"></a> -<span class="sourceLineNo">181</span> * occurs inside any of the futures<a name="line.181"></a> -<span class="sourceLineNo">182</span> */<a name="line.182"></a> -<span class="sourceLineNo">183</span> public static <T> void assertOnFutures(List<Future<T>> threadResults)<a name="line.183"></a> -<span class="sourceLineNo">184</span> throws InterruptedException, ExecutionException {<a name="line.184"></a> -<span class="sourceLineNo">185</span> for (Future<T> threadResult : threadResults) {<a name="line.185"></a> -<span class="sourceLineNo">186</span> try {<a name="line.186"></a> -<span class="sourceLineNo">187</span> threadResult.get();<a name="line.187"></a> -<span class="sourceLineNo">188</span> } catch (ExecutionException e) {<a name="line.188"></a> -<span class="sourceLineNo">189</span> if (e.getCause() instanceof AssertionError) {<a name="line.189"></a> -<span class="sourceLineNo">190</span> throw (AssertionError) e.getCause();<a name="line.190"></a> -<span class="sourceLineNo">191</span> }<a name="line.191"></a> -<span class="sourceLineNo">192</span> throw e;<a name="line.192"></a> -<span class="sourceLineNo">193</span> }<a name="line.193"></a> -<span class="sourceLineNo">194</span> }<a name="line.194"></a> -<span class="sourceLineNo">195</span> }<a name="line.195"></a> -<span class="sourceLineNo">196</span>}<a name="line.196"></a> +<span class="sourceLineNo">177</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.177"></a> +<span class="sourceLineNo">178</span> * from one of the futures<a name="line.178"></a> +<span class="sourceLineNo">179</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.179"></a> +<span class="sourceLineNo">180</span> * occurs inside any of the futures<a name="line.180"></a> +<span class="sourceLineNo">181</span> */<a name="line.181"></a> +<span class="sourceLineNo">182</span> public static void assertOnFutures(List<Future<?>> threadResults)<a name="line.182"></a> +<span class="sourceLineNo">183</span> throws InterruptedException, ExecutionException {<a name="line.183"></a> +<span class="sourceLineNo">184</span> for (Future<?> threadResult : threadResults) {<a name="line.184"></a> +<span class="sourceLineNo">185</span> try {<a name="line.185"></a> +<span class="sourceLineNo">186</span> threadResult.get();<a name="line.186"></a> +<span class="sourceLineNo">187</span> } catch (ExecutionException e) {<a name="line.187"></a> +<span class="sourceLineNo">188</span> if (e.getCause() instanceof AssertionError) {<a name="line.188"></a> +<span class="sourceLineNo">189</span> throw (AssertionError) e.getCause();<a name="line.189"></a> +<span class="sourceLineNo">190</span> }<a name="line.190"></a> +<span class="sourceLineNo">191</span> throw e;<a name="line.191"></a> +<span class="sourceLineNo">192</span> }<a name="line.192"></a> +<span class="sourceLineNo">193</span> }<a name="line.193"></a> +<span class="sourceLineNo">194</span> }<a name="line.194"></a> +<span class="sourceLineNo">195</span>}<a name="line.195"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.html index 6958746..fd38f4b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/MultithreadedTestUtil.html @@ -171,37 +171,36 @@ <span class="sourceLineNo">163</span> * Verify that no assertions have failed inside a future.<a name="line.163"></a> <span class="sourceLineNo">164</span> * Used for unit tests that spawn threads. E.g.,<a name="line.164"></a> <span class="sourceLineNo">165</span> * <p><a name="line.165"></a> -<span class="sourceLineNo">166</span> * <code><a name="line.166"></a> -<span class="sourceLineNo">167</span> * List<Future<Void>> results = Lists.newArrayList();<a name="line.167"></a> -<span class="sourceLineNo">168</span> * Future<Void> f = executor.submit(new Callable<Void> {<a name="line.168"></a> +<span class="sourceLineNo">166</span> * <pre><a name="line.166"></a> +<span class="sourceLineNo">167</span> * List&lt;Future&lt;Void>> results = Lists.newArrayList();<a name="line.167"></a> +<span class="sourceLineNo">168</span> * Future&lt;Void> f = executor.submit(new Callable&lt;Void> {<a name="line.168"></a> <span class="sourceLineNo">169</span> * public Void call() {<a name="line.169"></a> <span class="sourceLineNo">170</span> * assertTrue(someMethod());<a name="line.170"></a> <span class="sourceLineNo">171</span> * }<a name="line.171"></a> <span class="sourceLineNo">172</span> * });<a name="line.172"></a> <span class="sourceLineNo">173</span> * results.add(f);<a name="line.173"></a> <span class="sourceLineNo">174</span> * assertOnFutures(results);<a name="line.174"></a> -<span class="sourceLineNo">175</span> * </code><a name="line.175"></a> +<span class="sourceLineNo">175</span> * </pre><a name="line.175"></a> <span class="sourceLineNo">176</span> * @param threadResults A list of futures<a name="line.176"></a> -<span class="sourceLineNo">177</span> * @param <T><a name="line.177"></a> -<span class="sourceLineNo">178</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.178"></a> -<span class="sourceLineNo">179</span> * from one of the futures<a name="line.179"></a> -<span class="sourceLineNo">180</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.180"></a> -<span class="sourceLineNo">181</span> * occurs inside any of the futures<a name="line.181"></a> -<span class="sourceLineNo">182</span> */<a name="line.182"></a> -<span class="sourceLineNo">183</span> public static <T> void assertOnFutures(List<Future<T>> threadResults)<a name="line.183"></a> -<span class="sourceLineNo">184</span> throws InterruptedException, ExecutionException {<a name="line.184"></a> -<span class="sourceLineNo">185</span> for (Future<T> threadResult : threadResults) {<a name="line.185"></a> -<span class="sourceLineNo">186</span> try {<a name="line.186"></a> -<span class="sourceLineNo">187</span> threadResult.get();<a name="line.187"></a> -<span class="sourceLineNo">188</span> } catch (ExecutionException e) {<a name="line.188"></a> -<span class="sourceLineNo">189</span> if (e.getCause() instanceof AssertionError) {<a name="line.189"></a> -<span class="sourceLineNo">190</span> throw (AssertionError) e.getCause();<a name="line.190"></a> -<span class="sourceLineNo">191</span> }<a name="line.191"></a> -<span class="sourceLineNo">192</span> throw e;<a name="line.192"></a> -<span class="sourceLineNo">193</span> }<a name="line.193"></a> -<span class="sourceLineNo">194</span> }<a name="line.194"></a> -<span class="sourceLineNo">195</span> }<a name="line.195"></a> -<span class="sourceLineNo">196</span>}<a name="line.196"></a> +<span class="sourceLineNo">177</span> * @throws InterruptedException If interrupted when waiting for a result<a name="line.177"></a> +<span class="sourceLineNo">178</span> * from one of the futures<a name="line.178"></a> +<span class="sourceLineNo">179</span> * @throws ExecutionException If an exception other than AssertionError<a name="line.179"></a> +<span class="sourceLineNo">180</span> * occurs inside any of the futures<a name="line.180"></a> +<span class="sourceLineNo">181</span> */<a name="line.181"></a> +<span class="sourceLineNo">182</span> public static void assertOnFutures(List<Future<?>> threadResults)<a name="line.182"></a> +<span class="sourceLineNo">183</span> throws InterruptedException, ExecutionException {<a name="line.183"></a> +<span class="sourceLineNo">184</span> for (Future<?> threadResult : threadResults) {<a name="line.184"></a> +<span class="sourceLineNo">185</span> try {<a name="line.185"></a> +<span class="sourceLineNo">186</span> threadResult.get();<a name="line.186"></a> +<span class="sourceLineNo">187</span> } catch (ExecutionException e) {<a name="line.187"></a> +<span class="sourceLineNo">188</span> if (e.getCause() instanceof AssertionError) {<a name="line.188"></a> +<span class="sourceLineNo">189</span> throw (AssertionError) e.getCause();<a name="line.189"></a> +<span class="sourceLineNo">190</span> }<a name="line.190"></a> +<span class="sourceLineNo">191</span> throw e;<a name="line.191"></a> +<span class="sourceLineNo">192</span> }<a name="line.192"></a> +<span class="sourceLineNo">193</span> }<a name="line.193"></a> +<span class="sourceLineNo">194</span> }<a name="line.194"></a> +<span class="sourceLineNo">195</span>}<a name="line.195"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/4df09ed9/testdevapidocs/src-html/org/apache/hadoop/hbase/TestMetaTableAccessorNoCluster.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/TestMetaTableAccessorNoCluster.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/TestMetaTableAccessorNoCluster.html index 8d7bbf9..789e9f9 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/TestMetaTableAccessorNoCluster.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/TestMetaTableAccessorNoCluster.html @@ -130,7 +130,7 @@ <span class="sourceLineNo">122</span> /**<a name="line.122"></a> <span class="sourceLineNo">123</span> * Test that MetaTableAccessor will ride over server throwing<a name="line.123"></a> <span class="sourceLineNo">124</span> * "Server not running" IOEs.<a name="line.124"></a> -<span class="sourceLineNo">125</span> * @see @link {https://issues.apache.org/jira/browse/HBASE-3446}<a name="line.125"></a> +<span class="sourceLineNo">125</span> * @see <a href="https://issues.apache.org/jira/browse/HBASE-3446">HBASE-3446</a><a name="line.125"></a> <span class="sourceLineNo">126</span> * @throws IOException<a name="line.126"></a> <span class="sourceLineNo">127</span> * @throws InterruptedException<a name="line.127"></a> <span class="sourceLineNo">128</span> */<a name="line.128"></a>
