http://git-wip-us.apache.org/repos/asf/hbase-site/blob/476c54ed/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html index d9136a8..6b8f5c5 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.LogsComparator.html @@ -65,12 +65,12 @@ <span class="sourceLineNo">057</span>import org.apache.hadoop.hbase.replication.ReplicationQueues;<a name="line.57"></a> <span class="sourceLineNo">058</span>import org.apache.hadoop.hbase.replication.SystemTableWALEntryFilter;<a name="line.58"></a> <span class="sourceLineNo">059</span>import org.apache.hadoop.hbase.replication.WALEntryFilter;<a name="line.59"></a> -<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReaderThread.WALEntryBatch;<a name="line.60"></a> -<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.61"></a> -<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.util.Pair;<a name="line.62"></a> -<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.util.Threads;<a name="line.63"></a> -<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;<a name="line.64"></a> -<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.wal.WAL.Entry;<a name="line.65"></a> +<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.60"></a> +<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.util.Pair;<a name="line.61"></a> +<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.util.Threads;<a name="line.62"></a> +<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;<a name="line.63"></a> +<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.wal.WAL.Entry;<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">067</span>/**<a name="line.67"></a> <span class="sourceLineNo">068</span> * Class that handles the source of a replication stream.<a name="line.68"></a> @@ -456,7 +456,7 @@ <span class="sourceLineNo">448</span> this.sourceRunning = false;<a name="line.448"></a> <span class="sourceLineNo">449</span> Collection<ReplicationSourceShipperThread> workers = workerThreads.values();<a name="line.449"></a> <span class="sourceLineNo">450</span> for (ReplicationSourceShipperThread worker : workers) {<a name="line.450"></a> -<span class="sourceLineNo">451</span> worker.setWorkerRunning(false);<a name="line.451"></a> +<span class="sourceLineNo">451</span> worker.stopWorker();<a name="line.451"></a> <span class="sourceLineNo">452</span> worker.entryReader.interrupt();<a name="line.452"></a> <span class="sourceLineNo">453</span> worker.interrupt();<a name="line.453"></a> <span class="sourceLineNo">454</span> }<a name="line.454"></a> @@ -548,24 +548,20 @@ <span class="sourceLineNo">540</span> return sb.toString();<a name="line.540"></a> <span class="sourceLineNo">541</span> }<a name="line.541"></a> <span class="sourceLineNo">542</span><a name="line.542"></a> -<span class="sourceLineNo">543</span> /**<a name="line.543"></a> -<span class="sourceLineNo">544</span> * Get Replication Source Metrics<a name="line.544"></a> -<span class="sourceLineNo">545</span> * @return sourceMetrics<a name="line.545"></a> -<span class="sourceLineNo">546</span> */<a name="line.546"></a> -<span class="sourceLineNo">547</span> @Override<a name="line.547"></a> -<span class="sourceLineNo">548</span> public MetricsSource getSourceMetrics() {<a name="line.548"></a> -<span class="sourceLineNo">549</span> return this.metrics;<a name="line.549"></a> -<span class="sourceLineNo">550</span> }<a name="line.550"></a> -<span class="sourceLineNo">551</span><a name="line.551"></a> -<span class="sourceLineNo">552</span> @Override<a name="line.552"></a> -<span class="sourceLineNo">553</span> public void postShipEdits(List<Entry> entries, int batchSize) {<a name="line.553"></a> -<span class="sourceLineNo">554</span> if (throttler.isEnabled()) {<a name="line.554"></a> -<span class="sourceLineNo">555</span> throttler.addPushSize(batchSize);<a name="line.555"></a> -<span class="sourceLineNo">556</span> }<a name="line.556"></a> -<span class="sourceLineNo">557</span> totalReplicatedEdits.addAndGet(entries.size());<a name="line.557"></a> -<span class="sourceLineNo">558</span> totalBufferUsed.addAndGet(-batchSize);<a name="line.558"></a> -<span class="sourceLineNo">559</span> }<a name="line.559"></a> -<span class="sourceLineNo">560</span>}<a name="line.560"></a> +<span class="sourceLineNo">543</span> @Override<a name="line.543"></a> +<span class="sourceLineNo">544</span> public MetricsSource getSourceMetrics() {<a name="line.544"></a> +<span class="sourceLineNo">545</span> return this.metrics;<a name="line.545"></a> +<span class="sourceLineNo">546</span> }<a name="line.546"></a> +<span class="sourceLineNo">547</span><a name="line.547"></a> +<span class="sourceLineNo">548</span> @Override<a name="line.548"></a> +<span class="sourceLineNo">549</span> public void postShipEdits(List<Entry> entries, int batchSize) {<a name="line.549"></a> +<span class="sourceLineNo">550</span> if (throttler.isEnabled()) {<a name="line.550"></a> +<span class="sourceLineNo">551</span> throttler.addPushSize(batchSize);<a name="line.551"></a> +<span class="sourceLineNo">552</span> }<a name="line.552"></a> +<span class="sourceLineNo">553</span> totalReplicatedEdits.addAndGet(entries.size());<a name="line.553"></a> +<span class="sourceLineNo">554</span> totalBufferUsed.addAndGet(-batchSize);<a name="line.554"></a> +<span class="sourceLineNo">555</span> }<a name="line.555"></a> +<span class="sourceLineNo">556</span>}<a name="line.556"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/476c54ed/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html index d9136a8..6b8f5c5 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.html @@ -65,12 +65,12 @@ <span class="sourceLineNo">057</span>import org.apache.hadoop.hbase.replication.ReplicationQueues;<a name="line.57"></a> <span class="sourceLineNo">058</span>import org.apache.hadoop.hbase.replication.SystemTableWALEntryFilter;<a name="line.58"></a> <span class="sourceLineNo">059</span>import org.apache.hadoop.hbase.replication.WALEntryFilter;<a name="line.59"></a> -<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReaderThread.WALEntryBatch;<a name="line.60"></a> -<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.61"></a> -<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.util.Pair;<a name="line.62"></a> -<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.util.Threads;<a name="line.63"></a> -<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;<a name="line.64"></a> -<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.wal.WAL.Entry;<a name="line.65"></a> +<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.60"></a> +<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.util.Pair;<a name="line.61"></a> +<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.util.Threads;<a name="line.62"></a> +<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.wal.AbstractFSWALProvider;<a name="line.63"></a> +<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.wal.WAL.Entry;<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">067</span>/**<a name="line.67"></a> <span class="sourceLineNo">068</span> * Class that handles the source of a replication stream.<a name="line.68"></a> @@ -456,7 +456,7 @@ <span class="sourceLineNo">448</span> this.sourceRunning = false;<a name="line.448"></a> <span class="sourceLineNo">449</span> Collection<ReplicationSourceShipperThread> workers = workerThreads.values();<a name="line.449"></a> <span class="sourceLineNo">450</span> for (ReplicationSourceShipperThread worker : workers) {<a name="line.450"></a> -<span class="sourceLineNo">451</span> worker.setWorkerRunning(false);<a name="line.451"></a> +<span class="sourceLineNo">451</span> worker.stopWorker();<a name="line.451"></a> <span class="sourceLineNo">452</span> worker.entryReader.interrupt();<a name="line.452"></a> <span class="sourceLineNo">453</span> worker.interrupt();<a name="line.453"></a> <span class="sourceLineNo">454</span> }<a name="line.454"></a> @@ -548,24 +548,20 @@ <span class="sourceLineNo">540</span> return sb.toString();<a name="line.540"></a> <span class="sourceLineNo">541</span> }<a name="line.541"></a> <span class="sourceLineNo">542</span><a name="line.542"></a> -<span class="sourceLineNo">543</span> /**<a name="line.543"></a> -<span class="sourceLineNo">544</span> * Get Replication Source Metrics<a name="line.544"></a> -<span class="sourceLineNo">545</span> * @return sourceMetrics<a name="line.545"></a> -<span class="sourceLineNo">546</span> */<a name="line.546"></a> -<span class="sourceLineNo">547</span> @Override<a name="line.547"></a> -<span class="sourceLineNo">548</span> public MetricsSource getSourceMetrics() {<a name="line.548"></a> -<span class="sourceLineNo">549</span> return this.metrics;<a name="line.549"></a> -<span class="sourceLineNo">550</span> }<a name="line.550"></a> -<span class="sourceLineNo">551</span><a name="line.551"></a> -<span class="sourceLineNo">552</span> @Override<a name="line.552"></a> -<span class="sourceLineNo">553</span> public void postShipEdits(List<Entry> entries, int batchSize) {<a name="line.553"></a> -<span class="sourceLineNo">554</span> if (throttler.isEnabled()) {<a name="line.554"></a> -<span class="sourceLineNo">555</span> throttler.addPushSize(batchSize);<a name="line.555"></a> -<span class="sourceLineNo">556</span> }<a name="line.556"></a> -<span class="sourceLineNo">557</span> totalReplicatedEdits.addAndGet(entries.size());<a name="line.557"></a> -<span class="sourceLineNo">558</span> totalBufferUsed.addAndGet(-batchSize);<a name="line.558"></a> -<span class="sourceLineNo">559</span> }<a name="line.559"></a> -<span class="sourceLineNo">560</span>}<a name="line.560"></a> +<span class="sourceLineNo">543</span> @Override<a name="line.543"></a> +<span class="sourceLineNo">544</span> public MetricsSource getSourceMetrics() {<a name="line.544"></a> +<span class="sourceLineNo">545</span> return this.metrics;<a name="line.545"></a> +<span class="sourceLineNo">546</span> }<a name="line.546"></a> +<span class="sourceLineNo">547</span><a name="line.547"></a> +<span class="sourceLineNo">548</span> @Override<a name="line.548"></a> +<span class="sourceLineNo">549</span> public void postShipEdits(List<Entry> entries, int batchSize) {<a name="line.549"></a> +<span class="sourceLineNo">550</span> if (throttler.isEnabled()) {<a name="line.550"></a> +<span class="sourceLineNo">551</span> throttler.addPushSize(batchSize);<a name="line.551"></a> +<span class="sourceLineNo">552</span> }<a name="line.552"></a> +<span class="sourceLineNo">553</span> totalReplicatedEdits.addAndGet(entries.size());<a name="line.553"></a> +<span class="sourceLineNo">554</span> totalBufferUsed.addAndGet(-batchSize);<a name="line.554"></a> +<span class="sourceLineNo">555</span> }<a name="line.555"></a> +<span class="sourceLineNo">556</span>}<a name="line.556"></a>
