http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationFactory.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationFactory.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationFactory.html index 5272542..929de17 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationFactory.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationFactory.html @@ -39,39 +39,34 @@ <span class="sourceLineNo">031</span>@InterfaceAudience.Private<a name="line.31"></a> <span class="sourceLineNo">032</span>public class ReplicationFactory {<a name="line.32"></a> <span class="sourceLineNo">033</span><a name="line.33"></a> -<span class="sourceLineNo">034</span> public static final Class defaultReplicationQueueClass = ReplicationQueuesZKImpl.class;<a name="line.34"></a> -<span class="sourceLineNo">035</span><a name="line.35"></a> -<span class="sourceLineNo">036</span> public static ReplicationQueues getReplicationQueues(ReplicationQueuesArguments args)<a name="line.36"></a> -<span class="sourceLineNo">037</span> throws Exception {<a name="line.37"></a> -<span class="sourceLineNo">038</span> Class<?> classToBuild = args.getConf().getClass("hbase.region.replica." +<a name="line.38"></a> -<span class="sourceLineNo">039</span> "replication.replicationQueues.class", defaultReplicationQueueClass);<a name="line.39"></a> -<span class="sourceLineNo">040</span> return (ReplicationQueues) ConstructorUtils.invokeConstructor(classToBuild, args);<a name="line.40"></a> -<span class="sourceLineNo">041</span> }<a name="line.41"></a> -<span class="sourceLineNo">042</span><a name="line.42"></a> -<span class="sourceLineNo">043</span> public static ReplicationQueuesClient getReplicationQueuesClient(<a name="line.43"></a> -<span class="sourceLineNo">044</span> ReplicationQueuesClientArguments args) throws Exception {<a name="line.44"></a> -<span class="sourceLineNo">045</span> Class<?> classToBuild = args.getConf().getClass(<a name="line.45"></a> -<span class="sourceLineNo">046</span> "hbase.region.replica.replication.replicationQueuesClient.class",<a name="line.46"></a> -<span class="sourceLineNo">047</span> ReplicationQueuesClientZKImpl.class);<a name="line.47"></a> -<span class="sourceLineNo">048</span> return (ReplicationQueuesClient) ConstructorUtils.invokeConstructor(classToBuild, args);<a name="line.48"></a> +<span class="sourceLineNo">034</span> public static ReplicationQueues getReplicationQueues(ReplicationQueuesArguments args)<a name="line.34"></a> +<span class="sourceLineNo">035</span> throws Exception {<a name="line.35"></a> +<span class="sourceLineNo">036</span> return (ReplicationQueues) ConstructorUtils.invokeConstructor(ReplicationQueuesZKImpl.class,<a name="line.36"></a> +<span class="sourceLineNo">037</span> args);<a name="line.37"></a> +<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> public static ReplicationQueuesClient<a name="line.40"></a> +<span class="sourceLineNo">041</span> getReplicationQueuesClient(ReplicationQueuesClientArguments args) throws Exception {<a name="line.41"></a> +<span class="sourceLineNo">042</span> return (ReplicationQueuesClient) ConstructorUtils<a name="line.42"></a> +<span class="sourceLineNo">043</span> .invokeConstructor(ReplicationQueuesClientZKImpl.class, args);<a name="line.43"></a> +<span class="sourceLineNo">044</span> }<a name="line.44"></a> +<span class="sourceLineNo">045</span><a name="line.45"></a> +<span class="sourceLineNo">046</span> public static ReplicationPeers getReplicationPeers(final ZKWatcher zk, Configuration conf,<a name="line.46"></a> +<span class="sourceLineNo">047</span> Abortable abortable) {<a name="line.47"></a> +<span class="sourceLineNo">048</span> return getReplicationPeers(zk, conf, null, abortable);<a name="line.48"></a> <span class="sourceLineNo">049</span> }<a name="line.49"></a> <span class="sourceLineNo">050</span><a name="line.50"></a> <span class="sourceLineNo">051</span> public static ReplicationPeers getReplicationPeers(final ZKWatcher zk, Configuration conf,<a name="line.51"></a> -<span class="sourceLineNo">052</span> Abortable abortable) {<a name="line.52"></a> -<span class="sourceLineNo">053</span> return getReplicationPeers(zk, conf, null, abortable);<a name="line.53"></a> +<span class="sourceLineNo">052</span> final ReplicationQueuesClient queuesClient, Abortable abortable) {<a name="line.52"></a> +<span class="sourceLineNo">053</span> return new ReplicationPeersZKImpl(zk, conf, queuesClient, abortable);<a name="line.53"></a> <span class="sourceLineNo">054</span> }<a name="line.54"></a> <span class="sourceLineNo">055</span><a name="line.55"></a> -<span class="sourceLineNo">056</span> public static ReplicationPeers getReplicationPeers(final ZKWatcher zk, Configuration conf,<a name="line.56"></a> -<span class="sourceLineNo">057</span> final ReplicationQueuesClient queuesClient, Abortable abortable) {<a name="line.57"></a> -<span class="sourceLineNo">058</span> return new ReplicationPeersZKImpl(zk, conf, queuesClient, abortable);<a name="line.58"></a> -<span class="sourceLineNo">059</span> }<a name="line.59"></a> -<span class="sourceLineNo">060</span><a name="line.60"></a> -<span class="sourceLineNo">061</span> public static ReplicationTracker getReplicationTracker(ZKWatcher zookeeper,<a name="line.61"></a> -<span class="sourceLineNo">062</span> final ReplicationPeers replicationPeers, Configuration conf, Abortable abortable,<a name="line.62"></a> -<span class="sourceLineNo">063</span> Stoppable stopper) {<a name="line.63"></a> -<span class="sourceLineNo">064</span> return new ReplicationTrackerZKImpl(zookeeper, replicationPeers, conf, abortable, stopper);<a name="line.64"></a> -<span class="sourceLineNo">065</span> }<a name="line.65"></a> -<span class="sourceLineNo">066</span>}<a name="line.66"></a> +<span class="sourceLineNo">056</span> public static ReplicationTracker getReplicationTracker(ZKWatcher zookeeper,<a name="line.56"></a> +<span class="sourceLineNo">057</span> final ReplicationPeers replicationPeers, Configuration conf, Abortable abortable,<a name="line.57"></a> +<span class="sourceLineNo">058</span> Stoppable stopper) {<a name="line.58"></a> +<span class="sourceLineNo">059</span> return new ReplicationTrackerZKImpl(zookeeper, replicationPeers, conf, abortable, stopper);<a name="line.59"></a> +<span class="sourceLineNo">060</span> }<a name="line.60"></a> +<span class="sourceLineNo">061</span>}<a name="line.61"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.html index 3fae067..fc0477c 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.ReplicationPeerConfigBuilderImpl.html @@ -227,7 +227,7 @@ <span class="sourceLineNo">219</span> ReplicationPeerConfigBuilderImpl builder = new ReplicationPeerConfigBuilderImpl();<a name="line.219"></a> <span class="sourceLineNo">220</span> builder.setClusterKey(peerConfig.getClusterKey())<a name="line.220"></a> <span class="sourceLineNo">221</span> .setReplicationEndpointImpl(peerConfig.getReplicationEndpointImpl())<a name="line.221"></a> -<span class="sourceLineNo">222</span> .setPeerData(peerConfig.getPeerData()).setConfiguration(peerConfig.getConfiguration())<a name="line.222"></a> +<span class="sourceLineNo">222</span> .putAllPeerData(peerConfig.getPeerData()).putAllConfiguration(peerConfig.getConfiguration())<a name="line.222"></a> <span class="sourceLineNo">223</span> .setTableCFsMap(peerConfig.getTableCFsMap()).setNamespaces(peerConfig.getNamespaces())<a name="line.223"></a> <span class="sourceLineNo">224</span> .setReplicateAllUserTables(peerConfig.replicateAllUserTables())<a name="line.224"></a> <span class="sourceLineNo">225</span> .setExcludeTableCFsMap(peerConfig.getExcludeTableCFsMap())<a name="line.225"></a> @@ -272,14 +272,14 @@ <span class="sourceLineNo">264</span> }<a name="line.264"></a> <span class="sourceLineNo">265</span><a name="line.265"></a> <span class="sourceLineNo">266</span> @Override<a name="line.266"></a> -<span class="sourceLineNo">267</span> public ReplicationPeerConfigBuilder setPeerData(Map<byte[], byte[]> peerData) {<a name="line.267"></a> -<span class="sourceLineNo">268</span> this.peerData = peerData;<a name="line.268"></a> +<span class="sourceLineNo">267</span> public ReplicationPeerConfigBuilder putConfiguration(String key, String value) {<a name="line.267"></a> +<span class="sourceLineNo">268</span> this.configuration.put(key, value);<a name="line.268"></a> <span class="sourceLineNo">269</span> return this;<a name="line.269"></a> <span class="sourceLineNo">270</span> }<a name="line.270"></a> <span class="sourceLineNo">271</span><a name="line.271"></a> <span class="sourceLineNo">272</span> @Override<a name="line.272"></a> -<span class="sourceLineNo">273</span> public ReplicationPeerConfigBuilder setConfiguration(Map<String, String> configuration) {<a name="line.273"></a> -<span class="sourceLineNo">274</span> this.configuration = configuration;<a name="line.274"></a> +<span class="sourceLineNo">273</span> public ReplicationPeerConfigBuilder putPeerData(byte[] key, byte[] value) {<a name="line.273"></a> +<span class="sourceLineNo">274</span> this.peerData.put(key, value);<a name="line.274"></a> <span class="sourceLineNo">275</span> return this;<a name="line.275"></a> <span class="sourceLineNo">276</span> }<a name="line.276"></a> <span class="sourceLineNo">277</span><a name="line.277"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html index 3fae067..fc0477c 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfig.html @@ -227,7 +227,7 @@ <span class="sourceLineNo">219</span> ReplicationPeerConfigBuilderImpl builder = new ReplicationPeerConfigBuilderImpl();<a name="line.219"></a> <span class="sourceLineNo">220</span> builder.setClusterKey(peerConfig.getClusterKey())<a name="line.220"></a> <span class="sourceLineNo">221</span> .setReplicationEndpointImpl(peerConfig.getReplicationEndpointImpl())<a name="line.221"></a> -<span class="sourceLineNo">222</span> .setPeerData(peerConfig.getPeerData()).setConfiguration(peerConfig.getConfiguration())<a name="line.222"></a> +<span class="sourceLineNo">222</span> .putAllPeerData(peerConfig.getPeerData()).putAllConfiguration(peerConfig.getConfiguration())<a name="line.222"></a> <span class="sourceLineNo">223</span> .setTableCFsMap(peerConfig.getTableCFsMap()).setNamespaces(peerConfig.getNamespaces())<a name="line.223"></a> <span class="sourceLineNo">224</span> .setReplicateAllUserTables(peerConfig.replicateAllUserTables())<a name="line.224"></a> <span class="sourceLineNo">225</span> .setExcludeTableCFsMap(peerConfig.getExcludeTableCFsMap())<a name="line.225"></a> @@ -272,14 +272,14 @@ <span class="sourceLineNo">264</span> }<a name="line.264"></a> <span class="sourceLineNo">265</span><a name="line.265"></a> <span class="sourceLineNo">266</span> @Override<a name="line.266"></a> -<span class="sourceLineNo">267</span> public ReplicationPeerConfigBuilder setPeerData(Map<byte[], byte[]> peerData) {<a name="line.267"></a> -<span class="sourceLineNo">268</span> this.peerData = peerData;<a name="line.268"></a> +<span class="sourceLineNo">267</span> public ReplicationPeerConfigBuilder putConfiguration(String key, String value) {<a name="line.267"></a> +<span class="sourceLineNo">268</span> this.configuration.put(key, value);<a name="line.268"></a> <span class="sourceLineNo">269</span> return this;<a name="line.269"></a> <span class="sourceLineNo">270</span> }<a name="line.270"></a> <span class="sourceLineNo">271</span><a name="line.271"></a> <span class="sourceLineNo">272</span> @Override<a name="line.272"></a> -<span class="sourceLineNo">273</span> public ReplicationPeerConfigBuilder setConfiguration(Map<String, String> configuration) {<a name="line.273"></a> -<span class="sourceLineNo">274</span> this.configuration = configuration;<a name="line.274"></a> +<span class="sourceLineNo">273</span> public ReplicationPeerConfigBuilder putPeerData(byte[] key, byte[] value) {<a name="line.273"></a> +<span class="sourceLineNo">274</span> this.peerData.put(key, value);<a name="line.274"></a> <span class="sourceLineNo">275</span> return this;<a name="line.275"></a> <span class="sourceLineNo">276</span> }<a name="line.276"></a> <span class="sourceLineNo">277</span><a name="line.277"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b618ac40/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfigBuilder.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfigBuilder.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfigBuilder.html index 2376d92..03841fd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfigBuilder.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/ReplicationPeerConfigBuilder.html @@ -51,25 +51,35 @@ <span class="sourceLineNo">043</span> */<a name="line.43"></a> <span class="sourceLineNo">044</span> ReplicationPeerConfigBuilder setReplicationEndpointImpl(String replicationEndpointImpl);<a name="line.44"></a> <span class="sourceLineNo">045</span><a name="line.45"></a> -<span class="sourceLineNo">046</span> ReplicationPeerConfigBuilder setPeerData(Map<byte[], byte[]> peerData);<a name="line.46"></a> +<span class="sourceLineNo">046</span> ReplicationPeerConfigBuilder putConfiguration(String key, String value);<a name="line.46"></a> <span class="sourceLineNo">047</span><a name="line.47"></a> -<span class="sourceLineNo">048</span> ReplicationPeerConfigBuilder setConfiguration(Map<String, String> configuration);<a name="line.48"></a> -<span class="sourceLineNo">049</span><a name="line.49"></a> -<span class="sourceLineNo">050</span> ReplicationPeerConfigBuilder<a name="line.50"></a> -<span class="sourceLineNo">051</span> setTableCFsMap(Map<TableName, List<String>> tableCFsMap);<a name="line.51"></a> +<span class="sourceLineNo">048</span> default ReplicationPeerConfigBuilder putAllConfiguration(Map<String, String> configuration) {<a name="line.48"></a> +<span class="sourceLineNo">049</span> configuration.forEach(this::putConfiguration);<a name="line.49"></a> +<span class="sourceLineNo">050</span> return this;<a name="line.50"></a> +<span class="sourceLineNo">051</span> }<a name="line.51"></a> <span class="sourceLineNo">052</span><a name="line.52"></a> -<span class="sourceLineNo">053</span> ReplicationPeerConfigBuilder setNamespaces(Set<String> namespaces);<a name="line.53"></a> +<span class="sourceLineNo">053</span> ReplicationPeerConfigBuilder putPeerData(byte[] key, byte[] value);<a name="line.53"></a> <span class="sourceLineNo">054</span><a name="line.54"></a> -<span class="sourceLineNo">055</span> ReplicationPeerConfigBuilder setBandwidth(long bandwidth);<a name="line.55"></a> -<span class="sourceLineNo">056</span><a name="line.56"></a> -<span class="sourceLineNo">057</span> ReplicationPeerConfigBuilder setReplicateAllUserTables(boolean replicateAllUserTables);<a name="line.57"></a> -<span class="sourceLineNo">058</span><a name="line.58"></a> -<span class="sourceLineNo">059</span> ReplicationPeerConfigBuilder setExcludeTableCFsMap(Map<TableName, List<String>> tableCFsMap);<a name="line.59"></a> -<span class="sourceLineNo">060</span><a name="line.60"></a> -<span class="sourceLineNo">061</span> ReplicationPeerConfigBuilder setExcludeNamespaces(Set<String> namespaces);<a name="line.61"></a> +<span class="sourceLineNo">055</span> default ReplicationPeerConfigBuilder putAllPeerData(Map<byte[], byte[]> peerData) {<a name="line.55"></a> +<span class="sourceLineNo">056</span> peerData.forEach(this::putPeerData);<a name="line.56"></a> +<span class="sourceLineNo">057</span> return this;<a name="line.57"></a> +<span class="sourceLineNo">058</span> }<a name="line.58"></a> +<span class="sourceLineNo">059</span><a name="line.59"></a> +<span class="sourceLineNo">060</span> ReplicationPeerConfigBuilder<a name="line.60"></a> +<span class="sourceLineNo">061</span> setTableCFsMap(Map<TableName, List<String>> tableCFsMap);<a name="line.61"></a> <span class="sourceLineNo">062</span><a name="line.62"></a> -<span class="sourceLineNo">063</span> ReplicationPeerConfig build();<a name="line.63"></a> -<span class="sourceLineNo">064</span>}<a name="line.64"></a> +<span class="sourceLineNo">063</span> ReplicationPeerConfigBuilder setNamespaces(Set<String> namespaces);<a name="line.63"></a> +<span class="sourceLineNo">064</span><a name="line.64"></a> +<span class="sourceLineNo">065</span> ReplicationPeerConfigBuilder setBandwidth(long bandwidth);<a name="line.65"></a> +<span class="sourceLineNo">066</span><a name="line.66"></a> +<span class="sourceLineNo">067</span> ReplicationPeerConfigBuilder setReplicateAllUserTables(boolean replicateAllUserTables);<a name="line.67"></a> +<span class="sourceLineNo">068</span><a name="line.68"></a> +<span class="sourceLineNo">069</span> ReplicationPeerConfigBuilder setExcludeTableCFsMap(Map<TableName, List<String>> tableCFsMap);<a name="line.69"></a> +<span class="sourceLineNo">070</span><a name="line.70"></a> +<span class="sourceLineNo">071</span> ReplicationPeerConfigBuilder setExcludeNamespaces(Set<String> namespaces);<a name="line.71"></a> +<span class="sourceLineNo">072</span><a name="line.72"></a> +<span class="sourceLineNo">073</span> ReplicationPeerConfig build();<a name="line.73"></a> +<span class="sourceLineNo">074</span>}<a name="line.74"></a>
