http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/ReplicationManager.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/ReplicationManager.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/ReplicationManager.html index 85cb39c..849adb3 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/ReplicationManager.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/ReplicationManager.html @@ -145,69 +145,70 @@ <span class="sourceLineNo">137</span> checkNamespacesAndTableCfsConfigConflict(peerConfig.getExcludeNamespaces(),<a name="line.137"></a> <span class="sourceLineNo">138</span> peerConfig.getExcludeTableCFsMap());<a name="line.138"></a> <span class="sourceLineNo">139</span> } else {<a name="line.139"></a> -<span class="sourceLineNo">140</span> if ((peerConfig.getExcludeNamespaces() != null && !peerConfig.getNamespaces().isEmpty())<a name="line.140"></a> -<span class="sourceLineNo">141</span> || (peerConfig.getExcludeTableCFsMap() != null<a name="line.141"></a> -<span class="sourceLineNo">142</span> && !peerConfig.getTableCFsMap().isEmpty())) {<a name="line.142"></a> -<span class="sourceLineNo">143</span> throw new ReplicationException(<a name="line.143"></a> -<span class="sourceLineNo">144</span> "Need clean exclude-namespaces or exclude-table-cfs config firstly"<a name="line.144"></a> -<span class="sourceLineNo">145</span> + " when replicate_all flag is false");<a name="line.145"></a> -<span class="sourceLineNo">146</span> }<a name="line.146"></a> -<span class="sourceLineNo">147</span> checkNamespacesAndTableCfsConfigConflict(peerConfig.getNamespaces(),<a name="line.147"></a> -<span class="sourceLineNo">148</span> peerConfig.getTableCFsMap());<a name="line.148"></a> -<span class="sourceLineNo">149</span> }<a name="line.149"></a> -<span class="sourceLineNo">150</span> checkConfiguredWALEntryFilters(peerConfig);<a name="line.150"></a> -<span class="sourceLineNo">151</span> }<a name="line.151"></a> -<span class="sourceLineNo">152</span><a name="line.152"></a> -<span class="sourceLineNo">153</span> /**<a name="line.153"></a> -<span class="sourceLineNo">154</span> * Set a namespace in the peer config means that all tables in this namespace will be replicated<a name="line.154"></a> -<span class="sourceLineNo">155</span> * to the peer cluster.<a name="line.155"></a> -<span class="sourceLineNo">156</span> * 1. If peer config already has a namespace, then not allow set any table of this namespace<a name="line.156"></a> -<span class="sourceLineNo">157</span> * to the peer config.<a name="line.157"></a> -<span class="sourceLineNo">158</span> * 2. If peer config already has a table, then not allow set this table's namespace to the peer<a name="line.158"></a> -<span class="sourceLineNo">159</span> * config.<a name="line.159"></a> -<span class="sourceLineNo">160</span> *<a name="line.160"></a> -<span class="sourceLineNo">161</span> * Set a exclude namespace in the peer config means that all tables in this namespace can't be<a name="line.161"></a> -<span class="sourceLineNo">162</span> * replicated to the peer cluster.<a name="line.162"></a> -<span class="sourceLineNo">163</span> * 1. If peer config already has a exclude namespace, then not allow set any exclude table of<a name="line.163"></a> -<span class="sourceLineNo">164</span> * this namespace to the peer config.<a name="line.164"></a> -<span class="sourceLineNo">165</span> * 2. If peer config already has a exclude table, then not allow set this table's namespace<a name="line.165"></a> -<span class="sourceLineNo">166</span> * as a exclude namespace.<a name="line.166"></a> -<span class="sourceLineNo">167</span> */<a name="line.167"></a> -<span class="sourceLineNo">168</span> private void checkNamespacesAndTableCfsConfigConflict(Set<String> namespaces,<a name="line.168"></a> -<span class="sourceLineNo">169</span> Map<TableName, ? extends Collection<String>> tableCfs) throws ReplicationException {<a name="line.169"></a> -<span class="sourceLineNo">170</span> if (namespaces == null || namespaces.isEmpty()) {<a name="line.170"></a> -<span class="sourceLineNo">171</span> return;<a name="line.171"></a> -<span class="sourceLineNo">172</span> }<a name="line.172"></a> -<span class="sourceLineNo">173</span> if (tableCfs == null || tableCfs.isEmpty()) {<a name="line.173"></a> -<span class="sourceLineNo">174</span> return;<a name="line.174"></a> -<span class="sourceLineNo">175</span> }<a name="line.175"></a> -<span class="sourceLineNo">176</span> for (Map.Entry<TableName, ? extends Collection<String>> entry : tableCfs.entrySet()) {<a name="line.176"></a> -<span class="sourceLineNo">177</span> TableName table = entry.getKey();<a name="line.177"></a> -<span class="sourceLineNo">178</span> if (namespaces.contains(table.getNamespaceAsString())) {<a name="line.178"></a> -<span class="sourceLineNo">179</span> throw new ReplicationException("Table-cfs " + table + " is conflict with namespaces "<a name="line.179"></a> -<span class="sourceLineNo">180</span> + table.getNamespaceAsString() + " in peer config");<a name="line.180"></a> -<span class="sourceLineNo">181</span> }<a name="line.181"></a> -<span class="sourceLineNo">182</span> }<a name="line.182"></a> -<span class="sourceLineNo">183</span> }<a name="line.183"></a> -<span class="sourceLineNo">184</span><a name="line.184"></a> -<span class="sourceLineNo">185</span> private void checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig)<a name="line.185"></a> -<span class="sourceLineNo">186</span> throws IOException {<a name="line.186"></a> -<span class="sourceLineNo">187</span> String filterCSV = peerConfig.getConfiguration().<a name="line.187"></a> -<span class="sourceLineNo">188</span> get(BaseReplicationEndpoint.REPLICATION_WALENTRYFILTER_CONFIG_KEY);<a name="line.188"></a> -<span class="sourceLineNo">189</span> if (filterCSV != null && !filterCSV.isEmpty()){<a name="line.189"></a> -<span class="sourceLineNo">190</span> String [] filters = filterCSV.split(",");<a name="line.190"></a> -<span class="sourceLineNo">191</span> for (String filter : filters) {<a name="line.191"></a> -<span class="sourceLineNo">192</span> try {<a name="line.192"></a> -<span class="sourceLineNo">193</span> Class clazz = Class.forName(filter);<a name="line.193"></a> -<span class="sourceLineNo">194</span> Object o = clazz.newInstance();<a name="line.194"></a> -<span class="sourceLineNo">195</span> } catch (Exception e) {<a name="line.195"></a> -<span class="sourceLineNo">196</span> throw new DoNotRetryIOException("Configured WALEntryFilter " + filter +<a name="line.196"></a> -<span class="sourceLineNo">197</span> " could not be created. Failing add/update " + "peer operation.", e);<a name="line.197"></a> -<span class="sourceLineNo">198</span> }<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> -<span class="sourceLineNo">201</span> }<a name="line.201"></a> -<span class="sourceLineNo">202</span>}<a name="line.202"></a> +<span class="sourceLineNo">140</span> if ((peerConfig.getExcludeNamespaces() != null<a name="line.140"></a> +<span class="sourceLineNo">141</span> && !peerConfig.getExcludeNamespaces().isEmpty())<a name="line.141"></a> +<span class="sourceLineNo">142</span> || (peerConfig.getExcludeTableCFsMap() != null<a name="line.142"></a> +<span class="sourceLineNo">143</span> && !peerConfig.getExcludeTableCFsMap().isEmpty())) {<a name="line.143"></a> +<span class="sourceLineNo">144</span> throw new ReplicationException(<a name="line.144"></a> +<span class="sourceLineNo">145</span> "Need clean exclude-namespaces or exclude-table-cfs config firstly"<a name="line.145"></a> +<span class="sourceLineNo">146</span> + " when replicate_all flag is false");<a name="line.146"></a> +<span class="sourceLineNo">147</span> }<a name="line.147"></a> +<span class="sourceLineNo">148</span> checkNamespacesAndTableCfsConfigConflict(peerConfig.getNamespaces(),<a name="line.148"></a> +<span class="sourceLineNo">149</span> peerConfig.getTableCFsMap());<a name="line.149"></a> +<span class="sourceLineNo">150</span> }<a name="line.150"></a> +<span class="sourceLineNo">151</span> checkConfiguredWALEntryFilters(peerConfig);<a name="line.151"></a> +<span class="sourceLineNo">152</span> }<a name="line.152"></a> +<span class="sourceLineNo">153</span><a name="line.153"></a> +<span class="sourceLineNo">154</span> /**<a name="line.154"></a> +<span class="sourceLineNo">155</span> * Set a namespace in the peer config means that all tables in this namespace will be replicated<a name="line.155"></a> +<span class="sourceLineNo">156</span> * to the peer cluster.<a name="line.156"></a> +<span class="sourceLineNo">157</span> * 1. If peer config already has a namespace, then not allow set any table of this namespace<a name="line.157"></a> +<span class="sourceLineNo">158</span> * to the peer config.<a name="line.158"></a> +<span class="sourceLineNo">159</span> * 2. If peer config already has a table, then not allow set this table's namespace to the peer<a name="line.159"></a> +<span class="sourceLineNo">160</span> * config.<a name="line.160"></a> +<span class="sourceLineNo">161</span> *<a name="line.161"></a> +<span class="sourceLineNo">162</span> * Set a exclude namespace in the peer config means that all tables in this namespace can't be<a name="line.162"></a> +<span class="sourceLineNo">163</span> * replicated to the peer cluster.<a name="line.163"></a> +<span class="sourceLineNo">164</span> * 1. If peer config already has a exclude namespace, then not allow set any exclude table of<a name="line.164"></a> +<span class="sourceLineNo">165</span> * this namespace to the peer config.<a name="line.165"></a> +<span class="sourceLineNo">166</span> * 2. If peer config already has a exclude table, then not allow set this table's namespace<a name="line.166"></a> +<span class="sourceLineNo">167</span> * as a exclude namespace.<a name="line.167"></a> +<span class="sourceLineNo">168</span> */<a name="line.168"></a> +<span class="sourceLineNo">169</span> private void checkNamespacesAndTableCfsConfigConflict(Set<String> namespaces,<a name="line.169"></a> +<span class="sourceLineNo">170</span> Map<TableName, ? extends Collection<String>> tableCfs) throws ReplicationException {<a name="line.170"></a> +<span class="sourceLineNo">171</span> if (namespaces == null || namespaces.isEmpty()) {<a name="line.171"></a> +<span class="sourceLineNo">172</span> return;<a name="line.172"></a> +<span class="sourceLineNo">173</span> }<a name="line.173"></a> +<span class="sourceLineNo">174</span> if (tableCfs == null || tableCfs.isEmpty()) {<a name="line.174"></a> +<span class="sourceLineNo">175</span> return;<a name="line.175"></a> +<span class="sourceLineNo">176</span> }<a name="line.176"></a> +<span class="sourceLineNo">177</span> for (Map.Entry<TableName, ? extends Collection<String>> entry : tableCfs.entrySet()) {<a name="line.177"></a> +<span class="sourceLineNo">178</span> TableName table = entry.getKey();<a name="line.178"></a> +<span class="sourceLineNo">179</span> if (namespaces.contains(table.getNamespaceAsString())) {<a name="line.179"></a> +<span class="sourceLineNo">180</span> throw new ReplicationException("Table-cfs " + table + " is conflict with namespaces "<a name="line.180"></a> +<span class="sourceLineNo">181</span> + table.getNamespaceAsString() + " in peer config");<a name="line.181"></a> +<span class="sourceLineNo">182</span> }<a name="line.182"></a> +<span class="sourceLineNo">183</span> }<a name="line.183"></a> +<span class="sourceLineNo">184</span> }<a name="line.184"></a> +<span class="sourceLineNo">185</span><a name="line.185"></a> +<span class="sourceLineNo">186</span> private void checkConfiguredWALEntryFilters(ReplicationPeerConfig peerConfig)<a name="line.186"></a> +<span class="sourceLineNo">187</span> throws IOException {<a name="line.187"></a> +<span class="sourceLineNo">188</span> String filterCSV = peerConfig.getConfiguration().<a name="line.188"></a> +<span class="sourceLineNo">189</span> get(BaseReplicationEndpoint.REPLICATION_WALENTRYFILTER_CONFIG_KEY);<a name="line.189"></a> +<span class="sourceLineNo">190</span> if (filterCSV != null && !filterCSV.isEmpty()){<a name="line.190"></a> +<span class="sourceLineNo">191</span> String [] filters = filterCSV.split(",");<a name="line.191"></a> +<span class="sourceLineNo">192</span> for (String filter : filters) {<a name="line.192"></a> +<span class="sourceLineNo">193</span> try {<a name="line.193"></a> +<span class="sourceLineNo">194</span> Class clazz = Class.forName(filter);<a name="line.194"></a> +<span class="sourceLineNo">195</span> Object o = clazz.newInstance();<a name="line.195"></a> +<span class="sourceLineNo">196</span> } catch (Exception e) {<a name="line.196"></a> +<span class="sourceLineNo">197</span> throw new DoNotRetryIOException("Configured WALEntryFilter " + filter +<a name="line.197"></a> +<span class="sourceLineNo">198</span> " could not be created. Failing add/update " + "peer operation.", e);<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> +<span class="sourceLineNo">201</span> }<a name="line.201"></a> +<span class="sourceLineNo">202</span> }<a name="line.202"></a> +<span class="sourceLineNo">203</span>}<a name="line.203"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.BufferNode.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.BufferNode.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.BufferNode.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.BufferNode.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.BufferNode.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html index a340fcd..24a8232 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html @@ -379,7 +379,7 @@ <span class="sourceLineNo">371</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.371"></a> <span class="sourceLineNo">372</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.372"></a> <span class="sourceLineNo">373</span> }<a name="line.373"></a> -<span class="sourceLineNo">374</span> };<a name="line.374"></a> +<span class="sourceLineNo">374</span> }<a name="line.374"></a> <span class="sourceLineNo">375</span>}<a name="line.375"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.LeaseRecovery.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.LeaseRecovery.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.LeaseRecovery.html index 6477df9..a8b0dbf 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.LeaseRecovery.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.LeaseRecovery.html @@ -657,7 +657,7 @@ <span class="sourceLineNo">649</span> slotsCache.offer(slot);<a name="line.649"></a> <span class="sourceLineNo">650</span> }<a name="line.650"></a> <span class="sourceLineNo">651</span><a name="line.651"></a> -<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE };<a name="line.652"></a> +<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE }<a name="line.652"></a> <span class="sourceLineNo">653</span><a name="line.653"></a> <span class="sourceLineNo">654</span> private long pushData(final PushType type, final ByteSlot slot,<a name="line.654"></a> <span class="sourceLineNo">655</span> final long procId, final long[] subProcIds) {<a name="line.655"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.PushType.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.PushType.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.PushType.html index 6477df9..a8b0dbf 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.PushType.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.PushType.html @@ -657,7 +657,7 @@ <span class="sourceLineNo">649</span> slotsCache.offer(slot);<a name="line.649"></a> <span class="sourceLineNo">650</span> }<a name="line.650"></a> <span class="sourceLineNo">651</span><a name="line.651"></a> -<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE };<a name="line.652"></a> +<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE }<a name="line.652"></a> <span class="sourceLineNo">653</span><a name="line.653"></a> <span class="sourceLineNo">654</span> private long pushData(final PushType type, final ByteSlot slot,<a name="line.654"></a> <span class="sourceLineNo">655</span> final long procId, final long[] subProcIds) {<a name="line.655"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.SyncMetrics.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.SyncMetrics.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.SyncMetrics.html index 6477df9..a8b0dbf 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.SyncMetrics.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.SyncMetrics.html @@ -657,7 +657,7 @@ <span class="sourceLineNo">649</span> slotsCache.offer(slot);<a name="line.649"></a> <span class="sourceLineNo">650</span> }<a name="line.650"></a> <span class="sourceLineNo">651</span><a name="line.651"></a> -<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE };<a name="line.652"></a> +<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE }<a name="line.652"></a> <span class="sourceLineNo">653</span><a name="line.653"></a> <span class="sourceLineNo">654</span> private long pushData(final PushType type, final ByteSlot slot,<a name="line.654"></a> <span class="sourceLineNo">655</span> final long procId, final long[] subProcIds) {<a name="line.655"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.html index 6477df9..a8b0dbf 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/WALProcedureStore.html @@ -657,7 +657,7 @@ <span class="sourceLineNo">649</span> slotsCache.offer(slot);<a name="line.649"></a> <span class="sourceLineNo">650</span> }<a name="line.650"></a> <span class="sourceLineNo">651</span><a name="line.651"></a> -<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE };<a name="line.652"></a> +<span class="sourceLineNo">652</span> private enum PushType { INSERT, UPDATE, DELETE }<a name="line.652"></a> <span class="sourceLineNo">653</span><a name="line.653"></a> <span class="sourceLineNo">654</span> private long pushData(final PushType type, final ByteSlot slot,<a name="line.654"></a> <span class="sourceLineNo">655</span> final long procId, final long[] subProcIds) {<a name="line.655"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html index 026c61e..a64a568 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/SpaceViolationPolicy.html @@ -49,7 +49,7 @@ <span class="sourceLineNo">041</span> /**<a name="line.41"></a> <span class="sourceLineNo">042</span> * Disallows any updates (but allows deletes and compactions) on the table(s).<a name="line.42"></a> <span class="sourceLineNo">043</span> */<a name="line.43"></a> -<span class="sourceLineNo">044</span> NO_INSERTS;<a name="line.44"></a> +<span class="sourceLineNo">044</span> NO_INSERTS<a name="line.44"></a> <span class="sourceLineNo">045</span>}<a name="line.45"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html index 076d9ae..985e2ef 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.Type.html @@ -75,7 +75,7 @@ <span class="sourceLineNo">067</span> int index = msg.indexOf(MSG_TYPE[i]);<a name="line.67"></a> <span class="sourceLineNo">068</span> if (index >= 0) {<a name="line.68"></a> <span class="sourceLineNo">069</span> String waitTimeStr = msg.substring(index + MSG_TYPE[i].length() + MSG_WAIT.length());<a name="line.69"></a> -<span class="sourceLineNo">070</span> type = Type.values()[i];;<a name="line.70"></a> +<span class="sourceLineNo">070</span> type = Type.values()[i];<a name="line.70"></a> <span class="sourceLineNo">071</span> waitInterval = timeFromString(waitTimeStr);<a name="line.71"></a> <span class="sourceLineNo">072</span> break;<a name="line.72"></a> <span class="sourceLineNo">073</span> }<a name="line.73"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d0f1a9f6/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.html b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.html index 076d9ae..985e2ef 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/quotas/ThrottlingException.html @@ -75,7 +75,7 @@ <span class="sourceLineNo">067</span> int index = msg.indexOf(MSG_TYPE[i]);<a name="line.67"></a> <span class="sourceLineNo">068</span> if (index >= 0) {<a name="line.68"></a> <span class="sourceLineNo">069</span> String waitTimeStr = msg.substring(index + MSG_TYPE[i].length() + MSG_WAIT.length());<a name="line.69"></a> -<span class="sourceLineNo">070</span> type = Type.values()[i];;<a name="line.70"></a> +<span class="sourceLineNo">070</span> type = Type.values()[i];<a name="line.70"></a> <span class="sourceLineNo">071</span> waitInterval = timeFromString(waitTimeStr);<a name="line.71"></a> <span class="sourceLineNo">072</span> break;<a name="line.72"></a> <span class="sourceLineNo">073</span> }<a name="line.73"></a>
