http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.RegionStatistics.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.RegionStatistics.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.RegionStatistics.html index 12cfca6..1e841d6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.RegionStatistics.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.RegionStatistics.html @@ -67,12 +67,12 @@ <span class="sourceLineNo">059</span> private int compactionPressure = 0;<a name="line.59"></a> <span class="sourceLineNo">060</span><a name="line.60"></a> <span class="sourceLineNo">061</span> public void update(RegionLoadStats currentStats) {<a name="line.61"></a> -<span class="sourceLineNo">062</span> this.memstoreLoad = currentStats.getMemstoreLoad();<a name="line.62"></a> +<span class="sourceLineNo">062</span> this.memstoreLoad = currentStats.getMemStoreLoad();<a name="line.62"></a> <span class="sourceLineNo">063</span> this.heapOccupancy = currentStats.getHeapOccupancy();<a name="line.63"></a> <span class="sourceLineNo">064</span> this.compactionPressure = currentStats.getCompactionPressure();<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> public int getMemstoreLoadPercent(){<a name="line.67"></a> +<span class="sourceLineNo">067</span> public int getMemStoreLoadPercent(){<a name="line.67"></a> <span class="sourceLineNo">068</span> return this.memstoreLoad;<a name="line.68"></a> <span class="sourceLineNo">069</span> }<a name="line.69"></a> <span class="sourceLineNo">070</span><a name="line.70"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.html index 12cfca6..1e841d6 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/backoff/ServerStatistics.html @@ -67,12 +67,12 @@ <span class="sourceLineNo">059</span> private int compactionPressure = 0;<a name="line.59"></a> <span class="sourceLineNo">060</span><a name="line.60"></a> <span class="sourceLineNo">061</span> public void update(RegionLoadStats currentStats) {<a name="line.61"></a> -<span class="sourceLineNo">062</span> this.memstoreLoad = currentStats.getMemstoreLoad();<a name="line.62"></a> +<span class="sourceLineNo">062</span> this.memstoreLoad = currentStats.getMemStoreLoad();<a name="line.62"></a> <span class="sourceLineNo">063</span> this.heapOccupancy = currentStats.getHeapOccupancy();<a name="line.63"></a> <span class="sourceLineNo">064</span> this.compactionPressure = currentStats.getCompactionPressure();<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> public int getMemstoreLoadPercent(){<a name="line.67"></a> +<span class="sourceLineNo">067</span> public int getMemStoreLoadPercent(){<a name="line.67"></a> <span class="sourceLineNo">068</span> return this.memstoreLoad;<a name="line.68"></a> <span class="sourceLineNo">069</span> }<a name="line.69"></a> <span class="sourceLineNo">070</span><a name="line.70"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.CachingBlockReader.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.CachingBlockReader.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.CachingBlockReader.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.CachingBlockReader.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.CachingBlockReader.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.FileInfo.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.FileInfo.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.FileInfo.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.FileInfo.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.FileInfo.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Reader.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Reader.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Reader.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Reader.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Reader.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Writer.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Writer.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Writer.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Writer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.Writer.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.WriterFactory.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.WriterFactory.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.WriterFactory.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.WriterFactory.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.WriterFactory.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.html index 85f0bf2..daafefd 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFile.html @@ -497,9 +497,9 @@ <span class="sourceLineNo">489</span><a name="line.489"></a> <span class="sourceLineNo">490</span> boolean isPrimaryReplicaReader();<a name="line.490"></a> <span class="sourceLineNo">491</span><a name="line.491"></a> -<span class="sourceLineNo">492</span> boolean shouldIncludeMemstoreTS();<a name="line.492"></a> +<span class="sourceLineNo">492</span> boolean shouldIncludeMemStoreTS();<a name="line.492"></a> <span class="sourceLineNo">493</span><a name="line.493"></a> -<span class="sourceLineNo">494</span> boolean isDecodeMemstoreTS();<a name="line.494"></a> +<span class="sourceLineNo">494</span> boolean isDecodeMemStoreTS();<a name="line.494"></a> <span class="sourceLineNo">495</span><a name="line.495"></a> <span class="sourceLineNo">496</span> DataBlockEncoding getEffectiveEncodingInCache(boolean isCompaction);<a name="line.496"></a> <span class="sourceLineNo">497</span><a name="line.497"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockIterator.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockIterator.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockIterator.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockIterator.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockIterator.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockWritable.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockWritable.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockWritable.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockWritable.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.BlockWritable.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReader.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReader.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReader.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReader.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReader.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReaderImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReaderImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReaderImpl.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReaderImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.FSReaderImpl.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Header.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Header.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Header.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Header.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Header.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.PrefetchedHeader.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.PrefetchedHeader.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.PrefetchedHeader.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.PrefetchedHeader.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.PrefetchedHeader.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.State.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.Writer.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.html index 8d10c84..e2853b8 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileBlock.html @@ -1396,7 +1396,7 @@ <span class="sourceLineNo">1388</span> /** Get the default decoder for blocks from this file. */<a name="line.1388"></a> <span class="sourceLineNo">1389</span> HFileBlockDecodingContext getDefaultBlockDecodingContext();<a name="line.1389"></a> <span class="sourceLineNo">1390</span><a name="line.1390"></a> -<span class="sourceLineNo">1391</span> void setIncludesMemstoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> +<span class="sourceLineNo">1391</span> void setIncludesMemStoreTS(boolean includesMemstoreTS);<a name="line.1391"></a> <span class="sourceLineNo">1392</span> void setDataBlockEncoder(HFileDataBlockEncoder encoder);<a name="line.1392"></a> <span class="sourceLineNo">1393</span><a name="line.1393"></a> <span class="sourceLineNo">1394</span> /**<a name="line.1394"></a> @@ -1818,7 +1818,7 @@ <span class="sourceLineNo">1810</span> }<a name="line.1810"></a> <span class="sourceLineNo">1811</span><a name="line.1811"></a> <span class="sourceLineNo">1812</span> @Override<a name="line.1812"></a> -<span class="sourceLineNo">1813</span> public void setIncludesMemstoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> +<span class="sourceLineNo">1813</span> public void setIncludesMemStoreTS(boolean includesMemstoreTS) {<a name="line.1813"></a> <span class="sourceLineNo">1814</span> this.fileContext.setIncludesMvcc(includesMemstoreTS);<a name="line.1814"></a> <span class="sourceLineNo">1815</span> }<a name="line.1815"></a> <span class="sourceLineNo">1816</span><a name="line.1816"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.BlockIndexNotLoadedException.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.BlockIndexNotLoadedException.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.BlockIndexNotLoadedException.html index 4c4f8d8..5e95917 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.BlockIndexNotLoadedException.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.BlockIndexNotLoadedException.html @@ -244,7 +244,7 @@ <span class="sourceLineNo">236</span> byte [] keyValueFormatVersion = fileInfo.get(HFileWriterImpl.KEY_VALUE_VERSION);<a name="line.236"></a> <span class="sourceLineNo">237</span> includesMemstoreTS = keyValueFormatVersion != null &&<a name="line.237"></a> <span class="sourceLineNo">238</span> Bytes.toInt(keyValueFormatVersion) == HFileWriterImpl.KEY_VALUE_VER_WITH_MEMSTORE;<a name="line.238"></a> -<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemstoreTS(includesMemstoreTS);<a name="line.239"></a> +<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemStoreTS(includesMemstoreTS);<a name="line.239"></a> <span class="sourceLineNo">240</span> if (includesMemstoreTS) {<a name="line.240"></a> <span class="sourceLineNo">241</span> decodeMemstoreTS = Bytes.toLong(fileInfo.get(HFileWriterImpl.MAX_MEMSTORE_TS_KEY)) > 0;<a name="line.241"></a> <span class="sourceLineNo">242</span> }<a name="line.242"></a> @@ -653,8 +653,8 @@ <span class="sourceLineNo">645</span> */<a name="line.645"></a> <span class="sourceLineNo">646</span> protected void readMvccVersion(final int offsetFromPos) {<a name="line.646"></a> <span class="sourceLineNo">647</span> // See if we even need to decode mvcc.<a name="line.647"></a> -<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemstoreTS()) return;<a name="line.648"></a> -<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemstoreTS()) {<a name="line.649"></a> +<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemStoreTS()) return;<a name="line.648"></a> +<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemStoreTS()) {<a name="line.649"></a> <span class="sourceLineNo">650</span> currMemstoreTS = 0;<a name="line.650"></a> <span class="sourceLineNo">651</span> currMemstoreTSLen = 1;<a name="line.651"></a> <span class="sourceLineNo">652</span> return;<a name="line.652"></a> @@ -749,7 +749,7 @@ <span class="sourceLineNo">741</span> // add the two bytes read for the tags.<a name="line.741"></a> <span class="sourceLineNo">742</span> offsetFromPos += tlen + (Bytes.SIZEOF_SHORT);<a name="line.742"></a> <span class="sourceLineNo">743</span> }<a name="line.743"></a> -<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.744"></a> +<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.744"></a> <span class="sourceLineNo">745</span> // Directly read the mvcc based on current position<a name="line.745"></a> <span class="sourceLineNo">746</span> readMvccVersion(offsetFromPos);<a name="line.746"></a> <span class="sourceLineNo">747</span> }<a name="line.747"></a> @@ -881,7 +881,7 @@ <span class="sourceLineNo">873</span> return false;<a name="line.873"></a> <span class="sourceLineNo">874</span> }<a name="line.874"></a> <span class="sourceLineNo">875</span><a name="line.875"></a> -<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given <a name="line.876"></a> +<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given<a name="line.876"></a> <span class="sourceLineNo">877</span> // seekBefore key. We will go ahead by reading the next block that satisfies the<a name="line.877"></a> <span class="sourceLineNo">878</span> // given key. Return the current block before reading the next one.<a name="line.878"></a> <span class="sourceLineNo">879</span> reader.returnBlock(seekToBlock);<a name="line.879"></a> @@ -953,7 +953,7 @@ <span class="sourceLineNo">945</span> Cell ret;<a name="line.945"></a> <span class="sourceLineNo">946</span> int cellBufSize = getKVBufSize();<a name="line.946"></a> <span class="sourceLineNo">947</span> long seqId = 0l;<a name="line.947"></a> -<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.948"></a> +<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.948"></a> <span class="sourceLineNo">949</span> seqId = currMemstoreTS;<a name="line.949"></a> <span class="sourceLineNo">950</span> }<a name="line.950"></a> <span class="sourceLineNo">951</span> if (blockBuffer.hasArray()) {<a name="line.951"></a> @@ -995,7 +995,7 @@ <span class="sourceLineNo">987</span> + keyPair.getSecond(), currKeyLen);<a name="line.987"></a> <span class="sourceLineNo">988</span> } else {<a name="line.988"></a> <span class="sourceLineNo">989</span> // Better to do a copy here instead of holding on to this BB so that<a name="line.989"></a> -<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used <a name="line.990"></a> +<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used<a name="line.990"></a> <span class="sourceLineNo">991</span> // in HalfStoreFileReader to get the firstkey and lastkey by creating a new scanner<a name="line.991"></a> <span class="sourceLineNo">992</span> // every time. So holding onto the BB (incase of DBB) is not advised here.<a name="line.992"></a> <span class="sourceLineNo">993</span> byte[] key = new byte[currKeyLen];<a name="line.993"></a> @@ -1283,11 +1283,11 @@ <span class="sourceLineNo">1275</span> protected boolean decodeMemstoreTS = false;<a name="line.1275"></a> <span class="sourceLineNo">1276</span><a name="line.1276"></a> <span class="sourceLineNo">1277</span><a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public boolean isDecodeMemstoreTS() {<a name="line.1278"></a> +<span class="sourceLineNo">1278</span> public boolean isDecodeMemStoreTS() {<a name="line.1278"></a> <span class="sourceLineNo">1279</span> return this.decodeMemstoreTS;<a name="line.1279"></a> <span class="sourceLineNo">1280</span> }<a name="line.1280"></a> <span class="sourceLineNo">1281</span><a name="line.1281"></a> -<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemstoreTS() {<a name="line.1282"></a> +<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemStoreTS() {<a name="line.1282"></a> <span class="sourceLineNo">1283</span> return includesMemstoreTS;<a name="line.1283"></a> <span class="sourceLineNo">1284</span> }<a name="line.1284"></a> <span class="sourceLineNo">1285</span><a name="line.1285"></a> @@ -1791,7 +1791,7 @@ <span class="sourceLineNo">1783</span> protected HFileContext createHFileContext(FSDataInputStreamWrapper fsdis, long fileSize,<a name="line.1783"></a> <span class="sourceLineNo">1784</span> HFileSystem hfs, Path path, FixedFileTrailer trailer) throws IOException {<a name="line.1784"></a> <span class="sourceLineNo">1785</span> HFileContextBuilder builder = new HFileContextBuilder()<a name="line.1785"></a> -<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemstoreTS())<a name="line.1786"></a> +<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemStoreTS())<a name="line.1786"></a> <span class="sourceLineNo">1787</span> .withHBaseCheckSum(true)<a name="line.1787"></a> <span class="sourceLineNo">1788</span> .withHFileName(this.getName())<a name="line.1788"></a> <span class="sourceLineNo">1789</span> .withCompression(this.compressAlgo);<a name="line.1789"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.EncodedScanner.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.EncodedScanner.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.EncodedScanner.html index 4c4f8d8..5e95917 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.EncodedScanner.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.EncodedScanner.html @@ -244,7 +244,7 @@ <span class="sourceLineNo">236</span> byte [] keyValueFormatVersion = fileInfo.get(HFileWriterImpl.KEY_VALUE_VERSION);<a name="line.236"></a> <span class="sourceLineNo">237</span> includesMemstoreTS = keyValueFormatVersion != null &&<a name="line.237"></a> <span class="sourceLineNo">238</span> Bytes.toInt(keyValueFormatVersion) == HFileWriterImpl.KEY_VALUE_VER_WITH_MEMSTORE;<a name="line.238"></a> -<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemstoreTS(includesMemstoreTS);<a name="line.239"></a> +<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemStoreTS(includesMemstoreTS);<a name="line.239"></a> <span class="sourceLineNo">240</span> if (includesMemstoreTS) {<a name="line.240"></a> <span class="sourceLineNo">241</span> decodeMemstoreTS = Bytes.toLong(fileInfo.get(HFileWriterImpl.MAX_MEMSTORE_TS_KEY)) > 0;<a name="line.241"></a> <span class="sourceLineNo">242</span> }<a name="line.242"></a> @@ -653,8 +653,8 @@ <span class="sourceLineNo">645</span> */<a name="line.645"></a> <span class="sourceLineNo">646</span> protected void readMvccVersion(final int offsetFromPos) {<a name="line.646"></a> <span class="sourceLineNo">647</span> // See if we even need to decode mvcc.<a name="line.647"></a> -<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemstoreTS()) return;<a name="line.648"></a> -<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemstoreTS()) {<a name="line.649"></a> +<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemStoreTS()) return;<a name="line.648"></a> +<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemStoreTS()) {<a name="line.649"></a> <span class="sourceLineNo">650</span> currMemstoreTS = 0;<a name="line.650"></a> <span class="sourceLineNo">651</span> currMemstoreTSLen = 1;<a name="line.651"></a> <span class="sourceLineNo">652</span> return;<a name="line.652"></a> @@ -749,7 +749,7 @@ <span class="sourceLineNo">741</span> // add the two bytes read for the tags.<a name="line.741"></a> <span class="sourceLineNo">742</span> offsetFromPos += tlen + (Bytes.SIZEOF_SHORT);<a name="line.742"></a> <span class="sourceLineNo">743</span> }<a name="line.743"></a> -<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.744"></a> +<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.744"></a> <span class="sourceLineNo">745</span> // Directly read the mvcc based on current position<a name="line.745"></a> <span class="sourceLineNo">746</span> readMvccVersion(offsetFromPos);<a name="line.746"></a> <span class="sourceLineNo">747</span> }<a name="line.747"></a> @@ -881,7 +881,7 @@ <span class="sourceLineNo">873</span> return false;<a name="line.873"></a> <span class="sourceLineNo">874</span> }<a name="line.874"></a> <span class="sourceLineNo">875</span><a name="line.875"></a> -<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given <a name="line.876"></a> +<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given<a name="line.876"></a> <span class="sourceLineNo">877</span> // seekBefore key. We will go ahead by reading the next block that satisfies the<a name="line.877"></a> <span class="sourceLineNo">878</span> // given key. Return the current block before reading the next one.<a name="line.878"></a> <span class="sourceLineNo">879</span> reader.returnBlock(seekToBlock);<a name="line.879"></a> @@ -953,7 +953,7 @@ <span class="sourceLineNo">945</span> Cell ret;<a name="line.945"></a> <span class="sourceLineNo">946</span> int cellBufSize = getKVBufSize();<a name="line.946"></a> <span class="sourceLineNo">947</span> long seqId = 0l;<a name="line.947"></a> -<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.948"></a> +<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.948"></a> <span class="sourceLineNo">949</span> seqId = currMemstoreTS;<a name="line.949"></a> <span class="sourceLineNo">950</span> }<a name="line.950"></a> <span class="sourceLineNo">951</span> if (blockBuffer.hasArray()) {<a name="line.951"></a> @@ -995,7 +995,7 @@ <span class="sourceLineNo">987</span> + keyPair.getSecond(), currKeyLen);<a name="line.987"></a> <span class="sourceLineNo">988</span> } else {<a name="line.988"></a> <span class="sourceLineNo">989</span> // Better to do a copy here instead of holding on to this BB so that<a name="line.989"></a> -<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used <a name="line.990"></a> +<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used<a name="line.990"></a> <span class="sourceLineNo">991</span> // in HalfStoreFileReader to get the firstkey and lastkey by creating a new scanner<a name="line.991"></a> <span class="sourceLineNo">992</span> // every time. So holding onto the BB (incase of DBB) is not advised here.<a name="line.992"></a> <span class="sourceLineNo">993</span> byte[] key = new byte[currKeyLen];<a name="line.993"></a> @@ -1283,11 +1283,11 @@ <span class="sourceLineNo">1275</span> protected boolean decodeMemstoreTS = false;<a name="line.1275"></a> <span class="sourceLineNo">1276</span><a name="line.1276"></a> <span class="sourceLineNo">1277</span><a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public boolean isDecodeMemstoreTS() {<a name="line.1278"></a> +<span class="sourceLineNo">1278</span> public boolean isDecodeMemStoreTS() {<a name="line.1278"></a> <span class="sourceLineNo">1279</span> return this.decodeMemstoreTS;<a name="line.1279"></a> <span class="sourceLineNo">1280</span> }<a name="line.1280"></a> <span class="sourceLineNo">1281</span><a name="line.1281"></a> -<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemstoreTS() {<a name="line.1282"></a> +<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemStoreTS() {<a name="line.1282"></a> <span class="sourceLineNo">1283</span> return includesMemstoreTS;<a name="line.1283"></a> <span class="sourceLineNo">1284</span> }<a name="line.1284"></a> <span class="sourceLineNo">1285</span><a name="line.1285"></a> @@ -1791,7 +1791,7 @@ <span class="sourceLineNo">1783</span> protected HFileContext createHFileContext(FSDataInputStreamWrapper fsdis, long fileSize,<a name="line.1783"></a> <span class="sourceLineNo">1784</span> HFileSystem hfs, Path path, FixedFileTrailer trailer) throws IOException {<a name="line.1784"></a> <span class="sourceLineNo">1785</span> HFileContextBuilder builder = new HFileContextBuilder()<a name="line.1785"></a> -<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemstoreTS())<a name="line.1786"></a> +<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemStoreTS())<a name="line.1786"></a> <span class="sourceLineNo">1787</span> .withHBaseCheckSum(true)<a name="line.1787"></a> <span class="sourceLineNo">1788</span> .withHFileName(this.getName())<a name="line.1788"></a> <span class="sourceLineNo">1789</span> .withCompression(this.compressAlgo);<a name="line.1789"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.HFileScannerImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.HFileScannerImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.HFileScannerImpl.html index 4c4f8d8..5e95917 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.HFileScannerImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.HFileScannerImpl.html @@ -244,7 +244,7 @@ <span class="sourceLineNo">236</span> byte [] keyValueFormatVersion = fileInfo.get(HFileWriterImpl.KEY_VALUE_VERSION);<a name="line.236"></a> <span class="sourceLineNo">237</span> includesMemstoreTS = keyValueFormatVersion != null &&<a name="line.237"></a> <span class="sourceLineNo">238</span> Bytes.toInt(keyValueFormatVersion) == HFileWriterImpl.KEY_VALUE_VER_WITH_MEMSTORE;<a name="line.238"></a> -<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemstoreTS(includesMemstoreTS);<a name="line.239"></a> +<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemStoreTS(includesMemstoreTS);<a name="line.239"></a> <span class="sourceLineNo">240</span> if (includesMemstoreTS) {<a name="line.240"></a> <span class="sourceLineNo">241</span> decodeMemstoreTS = Bytes.toLong(fileInfo.get(HFileWriterImpl.MAX_MEMSTORE_TS_KEY)) > 0;<a name="line.241"></a> <span class="sourceLineNo">242</span> }<a name="line.242"></a> @@ -653,8 +653,8 @@ <span class="sourceLineNo">645</span> */<a name="line.645"></a> <span class="sourceLineNo">646</span> protected void readMvccVersion(final int offsetFromPos) {<a name="line.646"></a> <span class="sourceLineNo">647</span> // See if we even need to decode mvcc.<a name="line.647"></a> -<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemstoreTS()) return;<a name="line.648"></a> -<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemstoreTS()) {<a name="line.649"></a> +<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemStoreTS()) return;<a name="line.648"></a> +<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemStoreTS()) {<a name="line.649"></a> <span class="sourceLineNo">650</span> currMemstoreTS = 0;<a name="line.650"></a> <span class="sourceLineNo">651</span> currMemstoreTSLen = 1;<a name="line.651"></a> <span class="sourceLineNo">652</span> return;<a name="line.652"></a> @@ -749,7 +749,7 @@ <span class="sourceLineNo">741</span> // add the two bytes read for the tags.<a name="line.741"></a> <span class="sourceLineNo">742</span> offsetFromPos += tlen + (Bytes.SIZEOF_SHORT);<a name="line.742"></a> <span class="sourceLineNo">743</span> }<a name="line.743"></a> -<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.744"></a> +<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.744"></a> <span class="sourceLineNo">745</span> // Directly read the mvcc based on current position<a name="line.745"></a> <span class="sourceLineNo">746</span> readMvccVersion(offsetFromPos);<a name="line.746"></a> <span class="sourceLineNo">747</span> }<a name="line.747"></a> @@ -881,7 +881,7 @@ <span class="sourceLineNo">873</span> return false;<a name="line.873"></a> <span class="sourceLineNo">874</span> }<a name="line.874"></a> <span class="sourceLineNo">875</span><a name="line.875"></a> -<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given <a name="line.876"></a> +<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given<a name="line.876"></a> <span class="sourceLineNo">877</span> // seekBefore key. We will go ahead by reading the next block that satisfies the<a name="line.877"></a> <span class="sourceLineNo">878</span> // given key. Return the current block before reading the next one.<a name="line.878"></a> <span class="sourceLineNo">879</span> reader.returnBlock(seekToBlock);<a name="line.879"></a> @@ -953,7 +953,7 @@ <span class="sourceLineNo">945</span> Cell ret;<a name="line.945"></a> <span class="sourceLineNo">946</span> int cellBufSize = getKVBufSize();<a name="line.946"></a> <span class="sourceLineNo">947</span> long seqId = 0l;<a name="line.947"></a> -<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.948"></a> +<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.948"></a> <span class="sourceLineNo">949</span> seqId = currMemstoreTS;<a name="line.949"></a> <span class="sourceLineNo">950</span> }<a name="line.950"></a> <span class="sourceLineNo">951</span> if (blockBuffer.hasArray()) {<a name="line.951"></a> @@ -995,7 +995,7 @@ <span class="sourceLineNo">987</span> + keyPair.getSecond(), currKeyLen);<a name="line.987"></a> <span class="sourceLineNo">988</span> } else {<a name="line.988"></a> <span class="sourceLineNo">989</span> // Better to do a copy here instead of holding on to this BB so that<a name="line.989"></a> -<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used <a name="line.990"></a> +<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used<a name="line.990"></a> <span class="sourceLineNo">991</span> // in HalfStoreFileReader to get the firstkey and lastkey by creating a new scanner<a name="line.991"></a> <span class="sourceLineNo">992</span> // every time. So holding onto the BB (incase of DBB) is not advised here.<a name="line.992"></a> <span class="sourceLineNo">993</span> byte[] key = new byte[currKeyLen];<a name="line.993"></a> @@ -1283,11 +1283,11 @@ <span class="sourceLineNo">1275</span> protected boolean decodeMemstoreTS = false;<a name="line.1275"></a> <span class="sourceLineNo">1276</span><a name="line.1276"></a> <span class="sourceLineNo">1277</span><a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public boolean isDecodeMemstoreTS() {<a name="line.1278"></a> +<span class="sourceLineNo">1278</span> public boolean isDecodeMemStoreTS() {<a name="line.1278"></a> <span class="sourceLineNo">1279</span> return this.decodeMemstoreTS;<a name="line.1279"></a> <span class="sourceLineNo">1280</span> }<a name="line.1280"></a> <span class="sourceLineNo">1281</span><a name="line.1281"></a> -<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemstoreTS() {<a name="line.1282"></a> +<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemStoreTS() {<a name="line.1282"></a> <span class="sourceLineNo">1283</span> return includesMemstoreTS;<a name="line.1283"></a> <span class="sourceLineNo">1284</span> }<a name="line.1284"></a> <span class="sourceLineNo">1285</span><a name="line.1285"></a> @@ -1791,7 +1791,7 @@ <span class="sourceLineNo">1783</span> protected HFileContext createHFileContext(FSDataInputStreamWrapper fsdis, long fileSize,<a name="line.1783"></a> <span class="sourceLineNo">1784</span> HFileSystem hfs, Path path, FixedFileTrailer trailer) throws IOException {<a name="line.1784"></a> <span class="sourceLineNo">1785</span> HFileContextBuilder builder = new HFileContextBuilder()<a name="line.1785"></a> -<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemstoreTS())<a name="line.1786"></a> +<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemStoreTS())<a name="line.1786"></a> <span class="sourceLineNo">1787</span> .withHBaseCheckSum(true)<a name="line.1787"></a> <span class="sourceLineNo">1788</span> .withHFileName(this.getName())<a name="line.1788"></a> <span class="sourceLineNo">1789</span> .withCompression(this.compressAlgo);<a name="line.1789"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.NotSeekedException.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.NotSeekedException.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.NotSeekedException.html index 4c4f8d8..5e95917 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.NotSeekedException.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.NotSeekedException.html @@ -244,7 +244,7 @@ <span class="sourceLineNo">236</span> byte [] keyValueFormatVersion = fileInfo.get(HFileWriterImpl.KEY_VALUE_VERSION);<a name="line.236"></a> <span class="sourceLineNo">237</span> includesMemstoreTS = keyValueFormatVersion != null &&<a name="line.237"></a> <span class="sourceLineNo">238</span> Bytes.toInt(keyValueFormatVersion) == HFileWriterImpl.KEY_VALUE_VER_WITH_MEMSTORE;<a name="line.238"></a> -<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemstoreTS(includesMemstoreTS);<a name="line.239"></a> +<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemStoreTS(includesMemstoreTS);<a name="line.239"></a> <span class="sourceLineNo">240</span> if (includesMemstoreTS) {<a name="line.240"></a> <span class="sourceLineNo">241</span> decodeMemstoreTS = Bytes.toLong(fileInfo.get(HFileWriterImpl.MAX_MEMSTORE_TS_KEY)) > 0;<a name="line.241"></a> <span class="sourceLineNo">242</span> }<a name="line.242"></a> @@ -653,8 +653,8 @@ <span class="sourceLineNo">645</span> */<a name="line.645"></a> <span class="sourceLineNo">646</span> protected void readMvccVersion(final int offsetFromPos) {<a name="line.646"></a> <span class="sourceLineNo">647</span> // See if we even need to decode mvcc.<a name="line.647"></a> -<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemstoreTS()) return;<a name="line.648"></a> -<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemstoreTS()) {<a name="line.649"></a> +<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemStoreTS()) return;<a name="line.648"></a> +<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemStoreTS()) {<a name="line.649"></a> <span class="sourceLineNo">650</span> currMemstoreTS = 0;<a name="line.650"></a> <span class="sourceLineNo">651</span> currMemstoreTSLen = 1;<a name="line.651"></a> <span class="sourceLineNo">652</span> return;<a name="line.652"></a> @@ -749,7 +749,7 @@ <span class="sourceLineNo">741</span> // add the two bytes read for the tags.<a name="line.741"></a> <span class="sourceLineNo">742</span> offsetFromPos += tlen + (Bytes.SIZEOF_SHORT);<a name="line.742"></a> <span class="sourceLineNo">743</span> }<a name="line.743"></a> -<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.744"></a> +<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.744"></a> <span class="sourceLineNo">745</span> // Directly read the mvcc based on current position<a name="line.745"></a> <span class="sourceLineNo">746</span> readMvccVersion(offsetFromPos);<a name="line.746"></a> <span class="sourceLineNo">747</span> }<a name="line.747"></a> @@ -881,7 +881,7 @@ <span class="sourceLineNo">873</span> return false;<a name="line.873"></a> <span class="sourceLineNo">874</span> }<a name="line.874"></a> <span class="sourceLineNo">875</span><a name="line.875"></a> -<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given <a name="line.876"></a> +<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given<a name="line.876"></a> <span class="sourceLineNo">877</span> // seekBefore key. We will go ahead by reading the next block that satisfies the<a name="line.877"></a> <span class="sourceLineNo">878</span> // given key. Return the current block before reading the next one.<a name="line.878"></a> <span class="sourceLineNo">879</span> reader.returnBlock(seekToBlock);<a name="line.879"></a> @@ -953,7 +953,7 @@ <span class="sourceLineNo">945</span> Cell ret;<a name="line.945"></a> <span class="sourceLineNo">946</span> int cellBufSize = getKVBufSize();<a name="line.946"></a> <span class="sourceLineNo">947</span> long seqId = 0l;<a name="line.947"></a> -<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.948"></a> +<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.948"></a> <span class="sourceLineNo">949</span> seqId = currMemstoreTS;<a name="line.949"></a> <span class="sourceLineNo">950</span> }<a name="line.950"></a> <span class="sourceLineNo">951</span> if (blockBuffer.hasArray()) {<a name="line.951"></a> @@ -995,7 +995,7 @@ <span class="sourceLineNo">987</span> + keyPair.getSecond(), currKeyLen);<a name="line.987"></a> <span class="sourceLineNo">988</span> } else {<a name="line.988"></a> <span class="sourceLineNo">989</span> // Better to do a copy here instead of holding on to this BB so that<a name="line.989"></a> -<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used <a name="line.990"></a> +<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used<a name="line.990"></a> <span class="sourceLineNo">991</span> // in HalfStoreFileReader to get the firstkey and lastkey by creating a new scanner<a name="line.991"></a> <span class="sourceLineNo">992</span> // every time. So holding onto the BB (incase of DBB) is not advised here.<a name="line.992"></a> <span class="sourceLineNo">993</span> byte[] key = new byte[currKeyLen];<a name="line.993"></a> @@ -1283,11 +1283,11 @@ <span class="sourceLineNo">1275</span> protected boolean decodeMemstoreTS = false;<a name="line.1275"></a> <span class="sourceLineNo">1276</span><a name="line.1276"></a> <span class="sourceLineNo">1277</span><a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public boolean isDecodeMemstoreTS() {<a name="line.1278"></a> +<span class="sourceLineNo">1278</span> public boolean isDecodeMemStoreTS() {<a name="line.1278"></a> <span class="sourceLineNo">1279</span> return this.decodeMemstoreTS;<a name="line.1279"></a> <span class="sourceLineNo">1280</span> }<a name="line.1280"></a> <span class="sourceLineNo">1281</span><a name="line.1281"></a> -<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemstoreTS() {<a name="line.1282"></a> +<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemStoreTS() {<a name="line.1282"></a> <span class="sourceLineNo">1283</span> return includesMemstoreTS;<a name="line.1283"></a> <span class="sourceLineNo">1284</span> }<a name="line.1284"></a> <span class="sourceLineNo">1285</span><a name="line.1285"></a> @@ -1791,7 +1791,7 @@ <span class="sourceLineNo">1783</span> protected HFileContext createHFileContext(FSDataInputStreamWrapper fsdis, long fileSize,<a name="line.1783"></a> <span class="sourceLineNo">1784</span> HFileSystem hfs, Path path, FixedFileTrailer trailer) throws IOException {<a name="line.1784"></a> <span class="sourceLineNo">1785</span> HFileContextBuilder builder = new HFileContextBuilder()<a name="line.1785"></a> -<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemstoreTS())<a name="line.1786"></a> +<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemStoreTS())<a name="line.1786"></a> <span class="sourceLineNo">1787</span> .withHBaseCheckSum(true)<a name="line.1787"></a> <span class="sourceLineNo">1788</span> .withHFileName(this.getName())<a name="line.1788"></a> <span class="sourceLineNo">1789</span> .withCompression(this.compressAlgo);<a name="line.1789"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.html index 4c4f8d8..5e95917 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/HFileReaderImpl.html @@ -244,7 +244,7 @@ <span class="sourceLineNo">236</span> byte [] keyValueFormatVersion = fileInfo.get(HFileWriterImpl.KEY_VALUE_VERSION);<a name="line.236"></a> <span class="sourceLineNo">237</span> includesMemstoreTS = keyValueFormatVersion != null &&<a name="line.237"></a> <span class="sourceLineNo">238</span> Bytes.toInt(keyValueFormatVersion) == HFileWriterImpl.KEY_VALUE_VER_WITH_MEMSTORE;<a name="line.238"></a> -<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemstoreTS(includesMemstoreTS);<a name="line.239"></a> +<span class="sourceLineNo">239</span> fsBlockReader.setIncludesMemStoreTS(includesMemstoreTS);<a name="line.239"></a> <span class="sourceLineNo">240</span> if (includesMemstoreTS) {<a name="line.240"></a> <span class="sourceLineNo">241</span> decodeMemstoreTS = Bytes.toLong(fileInfo.get(HFileWriterImpl.MAX_MEMSTORE_TS_KEY)) > 0;<a name="line.241"></a> <span class="sourceLineNo">242</span> }<a name="line.242"></a> @@ -653,8 +653,8 @@ <span class="sourceLineNo">645</span> */<a name="line.645"></a> <span class="sourceLineNo">646</span> protected void readMvccVersion(final int offsetFromPos) {<a name="line.646"></a> <span class="sourceLineNo">647</span> // See if we even need to decode mvcc.<a name="line.647"></a> -<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemstoreTS()) return;<a name="line.648"></a> -<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemstoreTS()) {<a name="line.649"></a> +<span class="sourceLineNo">648</span> if (!this.reader.shouldIncludeMemStoreTS()) return;<a name="line.648"></a> +<span class="sourceLineNo">649</span> if (!this.reader.isDecodeMemStoreTS()) {<a name="line.649"></a> <span class="sourceLineNo">650</span> currMemstoreTS = 0;<a name="line.650"></a> <span class="sourceLineNo">651</span> currMemstoreTSLen = 1;<a name="line.651"></a> <span class="sourceLineNo">652</span> return;<a name="line.652"></a> @@ -749,7 +749,7 @@ <span class="sourceLineNo">741</span> // add the two bytes read for the tags.<a name="line.741"></a> <span class="sourceLineNo">742</span> offsetFromPos += tlen + (Bytes.SIZEOF_SHORT);<a name="line.742"></a> <span class="sourceLineNo">743</span> }<a name="line.743"></a> -<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.744"></a> +<span class="sourceLineNo">744</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.744"></a> <span class="sourceLineNo">745</span> // Directly read the mvcc based on current position<a name="line.745"></a> <span class="sourceLineNo">746</span> readMvccVersion(offsetFromPos);<a name="line.746"></a> <span class="sourceLineNo">747</span> }<a name="line.747"></a> @@ -881,7 +881,7 @@ <span class="sourceLineNo">873</span> return false;<a name="line.873"></a> <span class="sourceLineNo">874</span> }<a name="line.874"></a> <span class="sourceLineNo">875</span><a name="line.875"></a> -<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given <a name="line.876"></a> +<span class="sourceLineNo">876</span> // The first key in the current block 'seekToBlock' is greater than the given<a name="line.876"></a> <span class="sourceLineNo">877</span> // seekBefore key. We will go ahead by reading the next block that satisfies the<a name="line.877"></a> <span class="sourceLineNo">878</span> // given key. Return the current block before reading the next one.<a name="line.878"></a> <span class="sourceLineNo">879</span> reader.returnBlock(seekToBlock);<a name="line.879"></a> @@ -953,7 +953,7 @@ <span class="sourceLineNo">945</span> Cell ret;<a name="line.945"></a> <span class="sourceLineNo">946</span> int cellBufSize = getKVBufSize();<a name="line.946"></a> <span class="sourceLineNo">947</span> long seqId = 0l;<a name="line.947"></a> -<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemstoreTS()) {<a name="line.948"></a> +<span class="sourceLineNo">948</span> if (this.reader.shouldIncludeMemStoreTS()) {<a name="line.948"></a> <span class="sourceLineNo">949</span> seqId = currMemstoreTS;<a name="line.949"></a> <span class="sourceLineNo">950</span> }<a name="line.950"></a> <span class="sourceLineNo">951</span> if (blockBuffer.hasArray()) {<a name="line.951"></a> @@ -995,7 +995,7 @@ <span class="sourceLineNo">987</span> + keyPair.getSecond(), currKeyLen);<a name="line.987"></a> <span class="sourceLineNo">988</span> } else {<a name="line.988"></a> <span class="sourceLineNo">989</span> // Better to do a copy here instead of holding on to this BB so that<a name="line.989"></a> -<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used <a name="line.990"></a> +<span class="sourceLineNo">990</span> // we could release the blocks referring to this key. This key is specifically used<a name="line.990"></a> <span class="sourceLineNo">991</span> // in HalfStoreFileReader to get the firstkey and lastkey by creating a new scanner<a name="line.991"></a> <span class="sourceLineNo">992</span> // every time. So holding onto the BB (incase of DBB) is not advised here.<a name="line.992"></a> <span class="sourceLineNo">993</span> byte[] key = new byte[currKeyLen];<a name="line.993"></a> @@ -1283,11 +1283,11 @@ <span class="sourceLineNo">1275</span> protected boolean decodeMemstoreTS = false;<a name="line.1275"></a> <span class="sourceLineNo">1276</span><a name="line.1276"></a> <span class="sourceLineNo">1277</span><a name="line.1277"></a> -<span class="sourceLineNo">1278</span> public boolean isDecodeMemstoreTS() {<a name="line.1278"></a> +<span class="sourceLineNo">1278</span> public boolean isDecodeMemStoreTS() {<a name="line.1278"></a> <span class="sourceLineNo">1279</span> return this.decodeMemstoreTS;<a name="line.1279"></a> <span class="sourceLineNo">1280</span> }<a name="line.1280"></a> <span class="sourceLineNo">1281</span><a name="line.1281"></a> -<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemstoreTS() {<a name="line.1282"></a> +<span class="sourceLineNo">1282</span> public boolean shouldIncludeMemStoreTS() {<a name="line.1282"></a> <span class="sourceLineNo">1283</span> return includesMemstoreTS;<a name="line.1283"></a> <span class="sourceLineNo">1284</span> }<a name="line.1284"></a> <span class="sourceLineNo">1285</span><a name="line.1285"></a> @@ -1791,7 +1791,7 @@ <span class="sourceLineNo">1783</span> protected HFileContext createHFileContext(FSDataInputStreamWrapper fsdis, long fileSize,<a name="line.1783"></a> <span class="sourceLineNo">1784</span> HFileSystem hfs, Path path, FixedFileTrailer trailer) throws IOException {<a name="line.1784"></a> <span class="sourceLineNo">1785</span> HFileContextBuilder builder = new HFileContextBuilder()<a name="line.1785"></a> -<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemstoreTS())<a name="line.1786"></a> +<span class="sourceLineNo">1786</span> .withIncludesMvcc(shouldIncludeMemStoreTS())<a name="line.1786"></a> <span class="sourceLineNo">1787</span> .withHBaseCheckSum(true)<a name="line.1787"></a> <span class="sourceLineNo">1788</span> .withHFileName(this.getName())<a name="line.1788"></a> <span class="sourceLineNo">1789</span> .withCompression(this.compressAlgo);<a name="line.1789"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/io/util/MemorySizeUtil.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/util/MemorySizeUtil.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/util/MemorySizeUtil.html index f8985fd..a21c64b 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/util/MemorySizeUtil.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/util/MemorySizeUtil.html @@ -167,7 +167,7 @@ <span class="sourceLineNo">159</span> /**<a name="line.159"></a> <span class="sourceLineNo">160</span> * @return Pair of global memstore size and memory type(ie. on heap or off heap).<a name="line.160"></a> <span class="sourceLineNo">161</span> */<a name="line.161"></a> -<span class="sourceLineNo">162</span> public static Pair<Long, MemoryType> getGlobalMemstoreSize(Configuration conf) {<a name="line.162"></a> +<span class="sourceLineNo">162</span> public static Pair<Long, MemoryType> getGlobalMemStoreSize(Configuration conf) {<a name="line.162"></a> <span class="sourceLineNo">163</span> long offheapMSGlobal = conf.getLong(OFFHEAP_MEMSTORE_SIZE_KEY, 0);// Size in MBs<a name="line.163"></a> <span class="sourceLineNo">164</span> if (offheapMSGlobal > 0) {<a name="line.164"></a> <span class="sourceLineNo">165</span> // Off heap memstore size has not relevance when MSLAB is turned OFF. We will go with making<a name="line.165"></a> @@ -186,7 +186,7 @@ <span class="sourceLineNo">178</span> + " Going with on heap global memstore size ('" + MEMSTORE_SIZE_KEY + "')");<a name="line.178"></a> <span class="sourceLineNo">179</span> }<a name="line.179"></a> <span class="sourceLineNo">180</span> }<a name="line.180"></a> -<span class="sourceLineNo">181</span> return new Pair<>(getOnheapGlobalMemstoreSize(conf), MemoryType.HEAP);<a name="line.181"></a> +<span class="sourceLineNo">181</span> return new Pair<>(getOnheapGlobalMemStoreSize(conf), MemoryType.HEAP);<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> @@ -195,7 +195,7 @@ <span class="sourceLineNo">187</span> * @param conf<a name="line.187"></a> <span class="sourceLineNo">188</span> * @return the onheap global memstore limt<a name="line.188"></a> <span class="sourceLineNo">189</span> */<a name="line.189"></a> -<span class="sourceLineNo">190</span> public static long getOnheapGlobalMemstoreSize(Configuration conf) {<a name="line.190"></a> +<span class="sourceLineNo">190</span> public static long getOnheapGlobalMemStoreSize(Configuration conf) {<a name="line.190"></a> <span class="sourceLineNo">191</span> long max = -1L;<a name="line.191"></a> <span class="sourceLineNo">192</span> final MemoryUsage usage = safeGetHeapMemoryUsage();<a name="line.192"></a> <span class="sourceLineNo">193</span> if (usage != null) {<a name="line.193"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CandidateGenerator.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CandidateGenerator.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CandidateGenerator.html index 5c157b5..788fb93 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CandidateGenerator.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CandidateGenerator.html @@ -200,7 +200,7 @@ <span class="sourceLineNo">192</span> regionLoadFunctions = new CostFromRegionLoadFunction[] {<a name="line.192"></a> <span class="sourceLineNo">193</span> new ReadRequestCostFunction(conf),<a name="line.193"></a> <span class="sourceLineNo">194</span> new WriteRequestCostFunction(conf),<a name="line.194"></a> -<span class="sourceLineNo">195</span> new MemstoreSizeCostFunction(conf),<a name="line.195"></a> +<span class="sourceLineNo">195</span> new MemStoreSizeCostFunction(conf),<a name="line.195"></a> <span class="sourceLineNo">196</span> new StoreFileCostFunction(conf)<a name="line.196"></a> <span class="sourceLineNo">197</span> };<a name="line.197"></a> <span class="sourceLineNo">198</span> regionReplicaHostCostFunction = new RegionReplicaHostCostFunction(conf);<a name="line.198"></a> @@ -1676,13 +1676,13 @@ <span class="sourceLineNo">1668</span> * Compute the cost of total memstore size. The more unbalanced the higher the<a name="line.1668"></a> <span class="sourceLineNo">1669</span> * computed cost will be. This uses a rolling average of regionload.<a name="line.1669"></a> <span class="sourceLineNo">1670</span> */<a name="line.1670"></a> -<span class="sourceLineNo">1671</span> static class MemstoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> +<span class="sourceLineNo">1671</span> static class MemStoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> <span class="sourceLineNo">1672</span><a name="line.1672"></a> <span class="sourceLineNo">1673</span> private static final String MEMSTORE_SIZE_COST_KEY =<a name="line.1673"></a> <span class="sourceLineNo">1674</span> "hbase.master.balancer.stochastic.memstoreSizeCost";<a name="line.1674"></a> <span class="sourceLineNo">1675</span> private static final float DEFAULT_MEMSTORE_SIZE_COST = 5;<a name="line.1675"></a> <span class="sourceLineNo">1676</span><a name="line.1676"></a> -<span class="sourceLineNo">1677</span> MemstoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> +<span class="sourceLineNo">1677</span> MemStoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> <span class="sourceLineNo">1678</span> super(conf);<a name="line.1678"></a> <span class="sourceLineNo">1679</span> this.setMultiplier(conf.getFloat(MEMSTORE_SIZE_COST_KEY, DEFAULT_MEMSTORE_SIZE_COST));<a name="line.1679"></a> <span class="sourceLineNo">1680</span> }<a name="line.1680"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadAsRateFunction.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadAsRateFunction.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadAsRateFunction.html index 5c157b5..788fb93 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadAsRateFunction.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadAsRateFunction.html @@ -200,7 +200,7 @@ <span class="sourceLineNo">192</span> regionLoadFunctions = new CostFromRegionLoadFunction[] {<a name="line.192"></a> <span class="sourceLineNo">193</span> new ReadRequestCostFunction(conf),<a name="line.193"></a> <span class="sourceLineNo">194</span> new WriteRequestCostFunction(conf),<a name="line.194"></a> -<span class="sourceLineNo">195</span> new MemstoreSizeCostFunction(conf),<a name="line.195"></a> +<span class="sourceLineNo">195</span> new MemStoreSizeCostFunction(conf),<a name="line.195"></a> <span class="sourceLineNo">196</span> new StoreFileCostFunction(conf)<a name="line.196"></a> <span class="sourceLineNo">197</span> };<a name="line.197"></a> <span class="sourceLineNo">198</span> regionReplicaHostCostFunction = new RegionReplicaHostCostFunction(conf);<a name="line.198"></a> @@ -1676,13 +1676,13 @@ <span class="sourceLineNo">1668</span> * Compute the cost of total memstore size. The more unbalanced the higher the<a name="line.1668"></a> <span class="sourceLineNo">1669</span> * computed cost will be. This uses a rolling average of regionload.<a name="line.1669"></a> <span class="sourceLineNo">1670</span> */<a name="line.1670"></a> -<span class="sourceLineNo">1671</span> static class MemstoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> +<span class="sourceLineNo">1671</span> static class MemStoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> <span class="sourceLineNo">1672</span><a name="line.1672"></a> <span class="sourceLineNo">1673</span> private static final String MEMSTORE_SIZE_COST_KEY =<a name="line.1673"></a> <span class="sourceLineNo">1674</span> "hbase.master.balancer.stochastic.memstoreSizeCost";<a name="line.1674"></a> <span class="sourceLineNo">1675</span> private static final float DEFAULT_MEMSTORE_SIZE_COST = 5;<a name="line.1675"></a> <span class="sourceLineNo">1676</span><a name="line.1676"></a> -<span class="sourceLineNo">1677</span> MemstoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> +<span class="sourceLineNo">1677</span> MemStoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> <span class="sourceLineNo">1678</span> super(conf);<a name="line.1678"></a> <span class="sourceLineNo">1679</span> this.setMultiplier(conf.getFloat(MEMSTORE_SIZE_COST_KEY, DEFAULT_MEMSTORE_SIZE_COST));<a name="line.1679"></a> <span class="sourceLineNo">1680</span> }<a name="line.1680"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3332caca/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadFunction.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadFunction.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadFunction.html index 5c157b5..788fb93 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadFunction.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.CostFromRegionLoadFunction.html @@ -200,7 +200,7 @@ <span class="sourceLineNo">192</span> regionLoadFunctions = new CostFromRegionLoadFunction[] {<a name="line.192"></a> <span class="sourceLineNo">193</span> new ReadRequestCostFunction(conf),<a name="line.193"></a> <span class="sourceLineNo">194</span> new WriteRequestCostFunction(conf),<a name="line.194"></a> -<span class="sourceLineNo">195</span> new MemstoreSizeCostFunction(conf),<a name="line.195"></a> +<span class="sourceLineNo">195</span> new MemStoreSizeCostFunction(conf),<a name="line.195"></a> <span class="sourceLineNo">196</span> new StoreFileCostFunction(conf)<a name="line.196"></a> <span class="sourceLineNo">197</span> };<a name="line.197"></a> <span class="sourceLineNo">198</span> regionReplicaHostCostFunction = new RegionReplicaHostCostFunction(conf);<a name="line.198"></a> @@ -1676,13 +1676,13 @@ <span class="sourceLineNo">1668</span> * Compute the cost of total memstore size. The more unbalanced the higher the<a name="line.1668"></a> <span class="sourceLineNo">1669</span> * computed cost will be. This uses a rolling average of regionload.<a name="line.1669"></a> <span class="sourceLineNo">1670</span> */<a name="line.1670"></a> -<span class="sourceLineNo">1671</span> static class MemstoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> +<span class="sourceLineNo">1671</span> static class MemStoreSizeCostFunction extends CostFromRegionLoadAsRateFunction {<a name="line.1671"></a> <span class="sourceLineNo">1672</span><a name="line.1672"></a> <span class="sourceLineNo">1673</span> private static final String MEMSTORE_SIZE_COST_KEY =<a name="line.1673"></a> <span class="sourceLineNo">1674</span> "hbase.master.balancer.stochastic.memstoreSizeCost";<a name="line.1674"></a> <span class="sourceLineNo">1675</span> private static final float DEFAULT_MEMSTORE_SIZE_COST = 5;<a name="line.1675"></a> <span class="sourceLineNo">1676</span><a name="line.1676"></a> -<span class="sourceLineNo">1677</span> MemstoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> +<span class="sourceLineNo">1677</span> MemStoreSizeCostFunction(Configuration conf) {<a name="line.1677"></a> <span class="sourceLineNo">1678</span> super(conf);<a name="line.1678"></a> <span class="sourceLineNo">1679</span> this.setMultiplier(conf.getFloat(MEMSTORE_SIZE_COST_KEY, DEFAULT_MEMSTORE_SIZE_COST));<a name="line.1679"></a> <span class="sourceLineNo">1680</span> }<a name="line.1680"></a>
