http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6cafca90/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureScheduler.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureScheduler.html index 1507edd..f21fa1b 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureScheduler.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/ProcedureScheduler.html @@ -136,20 +136,24 @@ <span class="sourceLineNo">128</span> List<LockInfo> listLocks();<a name="line.128"></a> <span class="sourceLineNo">129</span><a name="line.129"></a> <span class="sourceLineNo">130</span> /**<a name="line.130"></a> -<span class="sourceLineNo">131</span> * Returns the number of elements in this queue.<a name="line.131"></a> -<span class="sourceLineNo">132</span> * @return the number of elements in this queue.<a name="line.132"></a> -<span class="sourceLineNo">133</span> */<a name="line.133"></a> -<span class="sourceLineNo">134</span> @VisibleForTesting<a name="line.134"></a> -<span class="sourceLineNo">135</span> int size();<a name="line.135"></a> -<span class="sourceLineNo">136</span><a name="line.136"></a> -<span class="sourceLineNo">137</span> /**<a name="line.137"></a> -<span class="sourceLineNo">138</span> * Clear current state of scheduler such that it is equivalent to newly created scheduler.<a name="line.138"></a> -<span class="sourceLineNo">139</span> * Used for testing failure and recovery. To emulate server crash/restart,<a name="line.139"></a> -<span class="sourceLineNo">140</span> * {@link ProcedureExecutor} resets its own state and calls clear() on scheduler.<a name="line.140"></a> -<span class="sourceLineNo">141</span> */<a name="line.141"></a> -<span class="sourceLineNo">142</span> @VisibleForTesting<a name="line.142"></a> -<span class="sourceLineNo">143</span> void clear();<a name="line.143"></a> -<span class="sourceLineNo">144</span>}<a name="line.144"></a> +<span class="sourceLineNo">131</span> * @return {@link LockInfo} for resource of specified type & name. null if resource is not locked.<a name="line.131"></a> +<span class="sourceLineNo">132</span> */<a name="line.132"></a> +<span class="sourceLineNo">133</span> LockInfo getLockInfoForResource(LockInfo.ResourceType resourceType, String resourceName);<a name="line.133"></a> +<span class="sourceLineNo">134</span> /**<a name="line.134"></a> +<span class="sourceLineNo">135</span> * Returns the number of elements in this queue.<a name="line.135"></a> +<span class="sourceLineNo">136</span> * @return the number of elements in this queue.<a name="line.136"></a> +<span class="sourceLineNo">137</span> */<a name="line.137"></a> +<span class="sourceLineNo">138</span> @VisibleForTesting<a name="line.138"></a> +<span class="sourceLineNo">139</span> int size();<a name="line.139"></a> +<span class="sourceLineNo">140</span><a name="line.140"></a> +<span class="sourceLineNo">141</span> /**<a name="line.141"></a> +<span class="sourceLineNo">142</span> * Clear current state of scheduler such that it is equivalent to newly created scheduler.<a name="line.142"></a> +<span class="sourceLineNo">143</span> * Used for testing failure and recovery. To emulate server crash/restart,<a name="line.143"></a> +<span class="sourceLineNo">144</span> * {@link ProcedureExecutor} resets its own state and calls clear() on scheduler.<a name="line.144"></a> +<span class="sourceLineNo">145</span> */<a name="line.145"></a> +<span class="sourceLineNo">146</span> @VisibleForTesting<a name="line.146"></a> +<span class="sourceLineNo">147</span> void clear();<a name="line.147"></a> +<span class="sourceLineNo">148</span>}<a name="line.148"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6cafca90/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/SimpleProcedureScheduler.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/SimpleProcedureScheduler.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/SimpleProcedureScheduler.html index c042716..7461c55 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/SimpleProcedureScheduler.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/SimpleProcedureScheduler.html @@ -89,7 +89,12 @@ <span class="sourceLineNo">081</span> public List<LockInfo> listLocks() {<a name="line.81"></a> <span class="sourceLineNo">082</span> return Collections.emptyList();<a name="line.82"></a> <span class="sourceLineNo">083</span> }<a name="line.83"></a> -<span class="sourceLineNo">084</span>}<a name="line.84"></a> +<span class="sourceLineNo">084</span><a name="line.84"></a> +<span class="sourceLineNo">085</span> @Override<a name="line.85"></a> +<span class="sourceLineNo">086</span> public LockInfo getLockInfoForResource(LockInfo.ResourceType resourceType, String resourceName) {<a name="line.86"></a> +<span class="sourceLineNo">087</span> return null;<a name="line.87"></a> +<span class="sourceLineNo">088</span> }<a name="line.88"></a> +<span class="sourceLineNo">089</span>}<a name="line.89"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6cafca90/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.Fetcher.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.Fetcher.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.Fetcher.html index b1dd573..23dbc5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.Fetcher.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.Fetcher.html @@ -198,11 +198,11 @@ <span class="sourceLineNo">190</span> // Prefetch online tables/namespaces<a name="line.190"></a> <span class="sourceLineNo">191</span> for (TableName table: QuotaCache.this.rsServices.getOnlineTables()) {<a name="line.191"></a> <span class="sourceLineNo">192</span> if (table.isSystemTable()) continue;<a name="line.192"></a> -<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.contains(table)) {<a name="line.193"></a> +<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.containsKey(table)) {<a name="line.193"></a> <span class="sourceLineNo">194</span> QuotaCache.this.tableQuotaCache.putIfAbsent(table, new QuotaState());<a name="line.194"></a> <span class="sourceLineNo">195</span> }<a name="line.195"></a> <span class="sourceLineNo">196</span> String ns = table.getNamespaceAsString();<a name="line.196"></a> -<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.contains(ns)) {<a name="line.197"></a> +<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.containsKey(ns)) {<a name="line.197"></a> <span class="sourceLineNo">198</span> QuotaCache.this.namespaceQuotaCache.putIfAbsent(ns, new QuotaState());<a name="line.198"></a> <span class="sourceLineNo">199</span> }<a name="line.199"></a> <span class="sourceLineNo">200</span> }<a name="line.200"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6cafca90/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.QuotaRefresherChore.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.QuotaRefresherChore.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.QuotaRefresherChore.html index b1dd573..23dbc5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.QuotaRefresherChore.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.QuotaRefresherChore.html @@ -198,11 +198,11 @@ <span class="sourceLineNo">190</span> // Prefetch online tables/namespaces<a name="line.190"></a> <span class="sourceLineNo">191</span> for (TableName table: QuotaCache.this.rsServices.getOnlineTables()) {<a name="line.191"></a> <span class="sourceLineNo">192</span> if (table.isSystemTable()) continue;<a name="line.192"></a> -<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.contains(table)) {<a name="line.193"></a> +<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.containsKey(table)) {<a name="line.193"></a> <span class="sourceLineNo">194</span> QuotaCache.this.tableQuotaCache.putIfAbsent(table, new QuotaState());<a name="line.194"></a> <span class="sourceLineNo">195</span> }<a name="line.195"></a> <span class="sourceLineNo">196</span> String ns = table.getNamespaceAsString();<a name="line.196"></a> -<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.contains(ns)) {<a name="line.197"></a> +<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.containsKey(ns)) {<a name="line.197"></a> <span class="sourceLineNo">198</span> QuotaCache.this.namespaceQuotaCache.putIfAbsent(ns, new QuotaState());<a name="line.198"></a> <span class="sourceLineNo">199</span> }<a name="line.199"></a> <span class="sourceLineNo">200</span> }<a name="line.200"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6cafca90/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.html index b1dd573..23dbc5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/QuotaCache.html @@ -198,11 +198,11 @@ <span class="sourceLineNo">190</span> // Prefetch online tables/namespaces<a name="line.190"></a> <span class="sourceLineNo">191</span> for (TableName table: QuotaCache.this.rsServices.getOnlineTables()) {<a name="line.191"></a> <span class="sourceLineNo">192</span> if (table.isSystemTable()) continue;<a name="line.192"></a> -<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.contains(table)) {<a name="line.193"></a> +<span class="sourceLineNo">193</span> if (!QuotaCache.this.tableQuotaCache.containsKey(table)) {<a name="line.193"></a> <span class="sourceLineNo">194</span> QuotaCache.this.tableQuotaCache.putIfAbsent(table, new QuotaState());<a name="line.194"></a> <span class="sourceLineNo">195</span> }<a name="line.195"></a> <span class="sourceLineNo">196</span> String ns = table.getNamespaceAsString();<a name="line.196"></a> -<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.contains(ns)) {<a name="line.197"></a> +<span class="sourceLineNo">197</span> if (!QuotaCache.this.namespaceQuotaCache.containsKey(ns)) {<a name="line.197"></a> <span class="sourceLineNo">198</span> QuotaCache.this.namespaceQuotaCache.putIfAbsent(ns, new QuotaState());<a name="line.198"></a> <span class="sourceLineNo">199</span> }<a name="line.199"></a> <span class="sourceLineNo">200</span> }<a name="line.200"></a>
