| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>Source code</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta name="description" content="source: package: org.apache.hadoop.hbase, class: RegionMetricsBuilder, class: RegionMetricsImpl"> |
| <meta name="generator" content="javadoc/SourceToHTMLConverter"> |
| <link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="Style"> |
| </head> |
| <body class="source-page"> |
| <main role="main"> |
| <div class="source-container"> |
| <pre><span class="source-line-no">001</span><span id="line-1">/*</span> |
| <span class="source-line-no">002</span><span id="line-2"> * Licensed to the Apache Software Foundation (ASF) under one</span> |
| <span class="source-line-no">003</span><span id="line-3"> * or more contributor license agreements. See the NOTICE file</span> |
| <span class="source-line-no">004</span><span id="line-4"> * distributed with this work for additional information</span> |
| <span class="source-line-no">005</span><span id="line-5"> * regarding copyright ownership. The ASF licenses this file</span> |
| <span class="source-line-no">006</span><span id="line-6"> * to you under the Apache License, Version 2.0 (the</span> |
| <span class="source-line-no">007</span><span id="line-7"> * "License"); you may not use this file except in compliance</span> |
| <span class="source-line-no">008</span><span id="line-8"> * with the License. You may obtain a copy of the License at</span> |
| <span class="source-line-no">009</span><span id="line-9"> *</span> |
| <span class="source-line-no">010</span><span id="line-10"> * http://www.apache.org/licenses/LICENSE-2.0</span> |
| <span class="source-line-no">011</span><span id="line-11"> *</span> |
| <span class="source-line-no">012</span><span id="line-12"> * Unless required by applicable law or agreed to in writing, software</span> |
| <span class="source-line-no">013</span><span id="line-13"> * distributed under the License is distributed on an "AS IS" BASIS,</span> |
| <span class="source-line-no">014</span><span id="line-14"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span> |
| <span class="source-line-no">015</span><span id="line-15"> * See the License for the specific language governing permissions and</span> |
| <span class="source-line-no">016</span><span id="line-16"> * limitations under the License.</span> |
| <span class="source-line-no">017</span><span id="line-17"> */</span> |
| <span class="source-line-no">018</span><span id="line-18">package org.apache.hadoop.hbase;</span> |
| <span class="source-line-no">019</span><span id="line-19"></span> |
| <span class="source-line-no">020</span><span id="line-20">import java.util.Collections;</span> |
| <span class="source-line-no">021</span><span id="line-21">import java.util.List;</span> |
| <span class="source-line-no">022</span><span id="line-22">import java.util.Map;</span> |
| <span class="source-line-no">023</span><span id="line-23">import java.util.stream.Collectors;</span> |
| <span class="source-line-no">024</span><span id="line-24">import org.apache.hadoop.hbase.client.CompactionState;</span> |
| <span class="source-line-no">025</span><span id="line-25">import org.apache.hadoop.hbase.util.Strings;</span> |
| <span class="source-line-no">026</span><span id="line-26">import org.apache.yetus.audience.InterfaceAudience;</span> |
| <span class="source-line-no">027</span><span id="line-27"></span> |
| <span class="source-line-no">028</span><span id="line-28">import org.apache.hbase.thirdparty.com.google.common.base.Preconditions;</span> |
| <span class="source-line-no">029</span><span id="line-29">import org.apache.hbase.thirdparty.com.google.protobuf.UnsafeByteOperations;</span> |
| <span class="source-line-no">030</span><span id="line-30"></span> |
| <span class="source-line-no">031</span><span id="line-31">import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;</span> |
| <span class="source-line-no">032</span><span id="line-32">import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos;</span> |
| <span class="source-line-no">033</span><span id="line-33">import org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos;</span> |
| <span class="source-line-no">034</span><span id="line-34">import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos;</span> |
| <span class="source-line-no">035</span><span id="line-35"></span> |
| <span class="source-line-no">036</span><span id="line-36">@InterfaceAudience.Private</span> |
| <span class="source-line-no">037</span><span id="line-37">public final class RegionMetricsBuilder {</span> |
| <span class="source-line-no">038</span><span id="line-38"></span> |
| <span class="source-line-no">039</span><span id="line-39"> public static List<RegionMetrics></span> |
| <span class="source-line-no">040</span><span id="line-40"> toRegionMetrics(AdminProtos.GetRegionLoadResponse regionLoadResponse) {</span> |
| <span class="source-line-no">041</span><span id="line-41"> return regionLoadResponse.getRegionLoadsList().stream()</span> |
| <span class="source-line-no">042</span><span id="line-42"> .map(RegionMetricsBuilder::toRegionMetrics).collect(Collectors.toList());</span> |
| <span class="source-line-no">043</span><span id="line-43"> }</span> |
| <span class="source-line-no">044</span><span id="line-44"></span> |
| <span class="source-line-no">045</span><span id="line-45"> public static RegionMetrics toRegionMetrics(ClusterStatusProtos.RegionLoad regionLoadPB) {</span> |
| <span class="source-line-no">046</span><span id="line-46"> return RegionMetricsBuilder</span> |
| <span class="source-line-no">047</span><span id="line-47"> .newBuilder(regionLoadPB.getRegionSpecifier().getValue().toByteArray())</span> |
| <span class="source-line-no">048</span><span id="line-48"> .setBloomFilterSize(new Size(regionLoadPB.getTotalStaticBloomSizeKB(), Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">049</span><span id="line-49"> .setCompactedCellCount(regionLoadPB.getCurrentCompactedKVs())</span> |
| <span class="source-line-no">050</span><span id="line-50"> .setCompactingCellCount(regionLoadPB.getTotalCompactingKVs())</span> |
| <span class="source-line-no">051</span><span id="line-51"> .setCompletedSequenceId(regionLoadPB.getCompleteSequenceId())</span> |
| <span class="source-line-no">052</span><span id="line-52"> .setDataLocality(regionLoadPB.hasDataLocality() ? regionLoadPB.getDataLocality() : 0.0f)</span> |
| <span class="source-line-no">053</span><span id="line-53"> .setDataLocalityForSsd(</span> |
| <span class="source-line-no">054</span><span id="line-54"> regionLoadPB.hasDataLocalityForSsd() ? regionLoadPB.getDataLocalityForSsd() : 0.0f)</span> |
| <span class="source-line-no">055</span><span id="line-55"> .setBlocksLocalWeight(</span> |
| <span class="source-line-no">056</span><span id="line-56"> regionLoadPB.hasBlocksLocalWeight() ? regionLoadPB.getBlocksLocalWeight() : 0)</span> |
| <span class="source-line-no">057</span><span id="line-57"> .setBlocksLocalWithSsdWeight(</span> |
| <span class="source-line-no">058</span><span id="line-58"> regionLoadPB.hasBlocksLocalWithSsdWeight() ? regionLoadPB.getBlocksLocalWithSsdWeight() : 0)</span> |
| <span class="source-line-no">059</span><span id="line-59"> .setBlocksTotalWeight(regionLoadPB.getBlocksTotalWeight())</span> |
| <span class="source-line-no">060</span><span id="line-60"> .setCompactionState(</span> |
| <span class="source-line-no">061</span><span id="line-61"> ProtobufUtil.createCompactionStateForRegionLoad(regionLoadPB.getCompactionState()))</span> |
| <span class="source-line-no">062</span><span id="line-62"> .setFilteredReadRequestCount(regionLoadPB.getFilteredReadRequestsCount())</span> |
| <span class="source-line-no">063</span><span id="line-63"> .setStoreFileUncompressedDataIndexSize(</span> |
| <span class="source-line-no">064</span><span id="line-64"> new Size(regionLoadPB.getTotalStaticIndexSizeKB(), Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">065</span><span id="line-65"> .setLastMajorCompactionTimestamp(regionLoadPB.getLastMajorCompactionTs())</span> |
| <span class="source-line-no">066</span><span id="line-66"> .setMemStoreSize(new Size(regionLoadPB.getMemStoreSizeMB(), Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">067</span><span id="line-67"> .setReadRequestCount(regionLoadPB.getReadRequestsCount())</span> |
| <span class="source-line-no">068</span><span id="line-68"> .setCpRequestCount(regionLoadPB.getCpRequestsCount())</span> |
| <span class="source-line-no">069</span><span id="line-69"> .setWriteRequestCount(regionLoadPB.getWriteRequestsCount())</span> |
| <span class="source-line-no">070</span><span id="line-70"> .setStoreFileIndexSize(new Size(regionLoadPB.getStorefileIndexSizeKB(), Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">071</span><span id="line-71"> .setStoreFileRootLevelIndexSize(</span> |
| <span class="source-line-no">072</span><span id="line-72"> new Size(regionLoadPB.getRootIndexSizeKB(), Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">073</span><span id="line-73"> .setStoreCount(regionLoadPB.getStores()).setStoreFileCount(regionLoadPB.getStorefiles())</span> |
| <span class="source-line-no">074</span><span id="line-74"> .setStoreRefCount(regionLoadPB.getStoreRefCount())</span> |
| <span class="source-line-no">075</span><span id="line-75"> .setMaxCompactedStoreFileRefCount(regionLoadPB.getMaxCompactedStoreFileRefCount())</span> |
| <span class="source-line-no">076</span><span id="line-76"> .setStoreFileSize(new Size(regionLoadPB.getStorefileSizeMB(), Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">077</span><span id="line-77"> .setStoreSequenceIds(regionLoadPB.getStoreCompleteSequenceIdList().stream()</span> |
| <span class="source-line-no">078</span><span id="line-78"> .collect(Collectors.toMap(</span> |
| <span class="source-line-no">079</span><span id="line-79"> (ClusterStatusProtos.StoreSequenceId s) -> s.getFamilyName().toByteArray(),</span> |
| <span class="source-line-no">080</span><span id="line-80"> ClusterStatusProtos.StoreSequenceId::getSequenceId)))</span> |
| <span class="source-line-no">081</span><span id="line-81"> .setUncompressedStoreFileSize(</span> |
| <span class="source-line-no">082</span><span id="line-82"> new Size(regionLoadPB.getStoreUncompressedSizeMB(), Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">083</span><span id="line-83"> .setRegionSizeMB(new Size(regionLoadPB.getRegionSizeMB(), Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">084</span><span id="line-84"> .setCurrentRegionCachedRatio(regionLoadPB.getCurrentRegionCachedRatio()).build();</span> |
| <span class="source-line-no">085</span><span id="line-85"> }</span> |
| <span class="source-line-no">086</span><span id="line-86"></span> |
| <span class="source-line-no">087</span><span id="line-87"> private static List<ClusterStatusProtos.StoreSequenceId></span> |
| <span class="source-line-no">088</span><span id="line-88"> toStoreSequenceId(Map<byte[], Long> ids) {</span> |
| <span class="source-line-no">089</span><span id="line-89"> return ids.entrySet().stream()</span> |
| <span class="source-line-no">090</span><span id="line-90"> .map(e -> ClusterStatusProtos.StoreSequenceId.newBuilder()</span> |
| <span class="source-line-no">091</span><span id="line-91"> .setFamilyName(UnsafeByteOperations.unsafeWrap(e.getKey())).setSequenceId(e.getValue())</span> |
| <span class="source-line-no">092</span><span id="line-92"> .build())</span> |
| <span class="source-line-no">093</span><span id="line-93"> .collect(Collectors.toList());</span> |
| <span class="source-line-no">094</span><span id="line-94"> }</span> |
| <span class="source-line-no">095</span><span id="line-95"></span> |
| <span class="source-line-no">096</span><span id="line-96"> public static ClusterStatusProtos.RegionLoad toRegionLoad(RegionMetrics regionMetrics) {</span> |
| <span class="source-line-no">097</span><span id="line-97"> return ClusterStatusProtos.RegionLoad.newBuilder()</span> |
| <span class="source-line-no">098</span><span id="line-98"> .setRegionSpecifier(HBaseProtos.RegionSpecifier.newBuilder()</span> |
| <span class="source-line-no">099</span><span id="line-99"> .setType(HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME)</span> |
| <span class="source-line-no">100</span><span id="line-100"> .setValue(UnsafeByteOperations.unsafeWrap(regionMetrics.getRegionName())).build())</span> |
| <span class="source-line-no">101</span><span id="line-101"> .setTotalStaticBloomSizeKB((int) regionMetrics.getBloomFilterSize().get(Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">102</span><span id="line-102"> .setCurrentCompactedKVs(regionMetrics.getCompactedCellCount())</span> |
| <span class="source-line-no">103</span><span id="line-103"> .setTotalCompactingKVs(regionMetrics.getCompactingCellCount())</span> |
| <span class="source-line-no">104</span><span id="line-104"> .setCompleteSequenceId(regionMetrics.getCompletedSequenceId())</span> |
| <span class="source-line-no">105</span><span id="line-105"> .setDataLocality(regionMetrics.getDataLocality())</span> |
| <span class="source-line-no">106</span><span id="line-106"> .setFilteredReadRequestsCount(regionMetrics.getFilteredReadRequestCount())</span> |
| <span class="source-line-no">107</span><span id="line-107"> .setTotalStaticIndexSizeKB(</span> |
| <span class="source-line-no">108</span><span id="line-108"> (int) regionMetrics.getStoreFileUncompressedDataIndexSize().get(Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">109</span><span id="line-109"> .setLastMajorCompactionTs(regionMetrics.getLastMajorCompactionTimestamp())</span> |
| <span class="source-line-no">110</span><span id="line-110"> .setMemStoreSizeMB((int) regionMetrics.getMemStoreSize().get(Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">111</span><span id="line-111"> .setReadRequestsCount(regionMetrics.getReadRequestCount())</span> |
| <span class="source-line-no">112</span><span id="line-112"> .setCpRequestsCount(regionMetrics.getCpRequestCount())</span> |
| <span class="source-line-no">113</span><span id="line-113"> .setWriteRequestsCount(regionMetrics.getWriteRequestCount())</span> |
| <span class="source-line-no">114</span><span id="line-114"> .setStorefileIndexSizeKB((long) regionMetrics.getStoreFileIndexSize().get(Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">115</span><span id="line-115"> .setRootIndexSizeKB(</span> |
| <span class="source-line-no">116</span><span id="line-116"> (int) regionMetrics.getStoreFileRootLevelIndexSize().get(Size.Unit.KILOBYTE))</span> |
| <span class="source-line-no">117</span><span id="line-117"> .setStores(regionMetrics.getStoreCount()).setStorefiles(regionMetrics.getStoreFileCount())</span> |
| <span class="source-line-no">118</span><span id="line-118"> .setStoreRefCount(regionMetrics.getStoreRefCount())</span> |
| <span class="source-line-no">119</span><span id="line-119"> .setMaxCompactedStoreFileRefCount(regionMetrics.getMaxCompactedStoreFileRefCount())</span> |
| <span class="source-line-no">120</span><span id="line-120"> .setStorefileSizeMB((int) regionMetrics.getStoreFileSize().get(Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">121</span><span id="line-121"> .addAllStoreCompleteSequenceId(toStoreSequenceId(regionMetrics.getStoreSequenceId()))</span> |
| <span class="source-line-no">122</span><span id="line-122"> .setStoreUncompressedSizeMB(</span> |
| <span class="source-line-no">123</span><span id="line-123"> (int) regionMetrics.getUncompressedStoreFileSize().get(Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">124</span><span id="line-124"> .setRegionSizeMB((int) regionMetrics.getRegionSizeMB().get(Size.Unit.MEGABYTE))</span> |
| <span class="source-line-no">125</span><span id="line-125"> .setCurrentRegionCachedRatio(regionMetrics.getCurrentRegionCachedRatio()).build();</span> |
| <span class="source-line-no">126</span><span id="line-126"> }</span> |
| <span class="source-line-no">127</span><span id="line-127"></span> |
| <span class="source-line-no">128</span><span id="line-128"> public static RegionMetricsBuilder newBuilder(byte[] name) {</span> |
| <span class="source-line-no">129</span><span id="line-129"> return new RegionMetricsBuilder(name);</span> |
| <span class="source-line-no">130</span><span id="line-130"> }</span> |
| <span class="source-line-no">131</span><span id="line-131"></span> |
| <span class="source-line-no">132</span><span id="line-132"> private final byte[] name;</span> |
| <span class="source-line-no">133</span><span id="line-133"> private int storeCount;</span> |
| <span class="source-line-no">134</span><span id="line-134"> private int storeFileCount;</span> |
| <span class="source-line-no">135</span><span id="line-135"> private int storeRefCount;</span> |
| <span class="source-line-no">136</span><span id="line-136"> private int maxCompactedStoreFileRefCount;</span> |
| <span class="source-line-no">137</span><span id="line-137"> private long compactingCellCount;</span> |
| <span class="source-line-no">138</span><span id="line-138"> private long compactedCellCount;</span> |
| <span class="source-line-no">139</span><span id="line-139"> private Size storeFileSize = Size.ZERO;</span> |
| <span class="source-line-no">140</span><span id="line-140"> private Size memStoreSize = Size.ZERO;</span> |
| <span class="source-line-no">141</span><span id="line-141"> private Size indexSize = Size.ZERO;</span> |
| <span class="source-line-no">142</span><span id="line-142"> private Size rootLevelIndexSize = Size.ZERO;</span> |
| <span class="source-line-no">143</span><span id="line-143"> private Size uncompressedDataIndexSize = Size.ZERO;</span> |
| <span class="source-line-no">144</span><span id="line-144"> private Size bloomFilterSize = Size.ZERO;</span> |
| <span class="source-line-no">145</span><span id="line-145"> private Size uncompressedStoreFileSize = Size.ZERO;</span> |
| <span class="source-line-no">146</span><span id="line-146"> private long writeRequestCount;</span> |
| <span class="source-line-no">147</span><span id="line-147"> private long readRequestCount;</span> |
| <span class="source-line-no">148</span><span id="line-148"> private long cpRequestCount;</span> |
| <span class="source-line-no">149</span><span id="line-149"> private long filteredReadRequestCount;</span> |
| <span class="source-line-no">150</span><span id="line-150"> private long completedSequenceId;</span> |
| <span class="source-line-no">151</span><span id="line-151"> private Map<byte[], Long> storeSequenceIds = Collections.emptyMap();</span> |
| <span class="source-line-no">152</span><span id="line-152"> private float dataLocality;</span> |
| <span class="source-line-no">153</span><span id="line-153"> private long lastMajorCompactionTimestamp;</span> |
| <span class="source-line-no">154</span><span id="line-154"> private float dataLocalityForSsd;</span> |
| <span class="source-line-no">155</span><span id="line-155"> private long blocksLocalWeight;</span> |
| <span class="source-line-no">156</span><span id="line-156"> private long blocksLocalWithSsdWeight;</span> |
| <span class="source-line-no">157</span><span id="line-157"> private long blocksTotalWeight;</span> |
| <span class="source-line-no">158</span><span id="line-158"> private CompactionState compactionState;</span> |
| <span class="source-line-no">159</span><span id="line-159"> private Size regionSizeMB = Size.ZERO;</span> |
| <span class="source-line-no">160</span><span id="line-160"> private float currentRegionCachedRatio;</span> |
| <span class="source-line-no">161</span><span id="line-161"></span> |
| <span class="source-line-no">162</span><span id="line-162"> private RegionMetricsBuilder(byte[] name) {</span> |
| <span class="source-line-no">163</span><span id="line-163"> this.name = name;</span> |
| <span class="source-line-no">164</span><span id="line-164"> }</span> |
| <span class="source-line-no">165</span><span id="line-165"></span> |
| <span class="source-line-no">166</span><span id="line-166"> public RegionMetricsBuilder setStoreCount(int value) {</span> |
| <span class="source-line-no">167</span><span id="line-167"> this.storeCount = value;</span> |
| <span class="source-line-no">168</span><span id="line-168"> return this;</span> |
| <span class="source-line-no">169</span><span id="line-169"> }</span> |
| <span class="source-line-no">170</span><span id="line-170"></span> |
| <span class="source-line-no">171</span><span id="line-171"> public RegionMetricsBuilder setStoreFileCount(int value) {</span> |
| <span class="source-line-no">172</span><span id="line-172"> this.storeFileCount = value;</span> |
| <span class="source-line-no">173</span><span id="line-173"> return this;</span> |
| <span class="source-line-no">174</span><span id="line-174"> }</span> |
| <span class="source-line-no">175</span><span id="line-175"></span> |
| <span class="source-line-no">176</span><span id="line-176"> public RegionMetricsBuilder setStoreRefCount(int value) {</span> |
| <span class="source-line-no">177</span><span id="line-177"> this.storeRefCount = value;</span> |
| <span class="source-line-no">178</span><span id="line-178"> return this;</span> |
| <span class="source-line-no">179</span><span id="line-179"> }</span> |
| <span class="source-line-no">180</span><span id="line-180"></span> |
| <span class="source-line-no">181</span><span id="line-181"> public RegionMetricsBuilder setMaxCompactedStoreFileRefCount(int value) {</span> |
| <span class="source-line-no">182</span><span id="line-182"> this.maxCompactedStoreFileRefCount = value;</span> |
| <span class="source-line-no">183</span><span id="line-183"> return this;</span> |
| <span class="source-line-no">184</span><span id="line-184"> }</span> |
| <span class="source-line-no">185</span><span id="line-185"></span> |
| <span class="source-line-no">186</span><span id="line-186"> public RegionMetricsBuilder setCompactingCellCount(long value) {</span> |
| <span class="source-line-no">187</span><span id="line-187"> this.compactingCellCount = value;</span> |
| <span class="source-line-no">188</span><span id="line-188"> return this;</span> |
| <span class="source-line-no">189</span><span id="line-189"> }</span> |
| <span class="source-line-no">190</span><span id="line-190"></span> |
| <span class="source-line-no">191</span><span id="line-191"> public RegionMetricsBuilder setCompactedCellCount(long value) {</span> |
| <span class="source-line-no">192</span><span id="line-192"> this.compactedCellCount = value;</span> |
| <span class="source-line-no">193</span><span id="line-193"> return this;</span> |
| <span class="source-line-no">194</span><span id="line-194"> }</span> |
| <span class="source-line-no">195</span><span id="line-195"></span> |
| <span class="source-line-no">196</span><span id="line-196"> public RegionMetricsBuilder setStoreFileSize(Size value) {</span> |
| <span class="source-line-no">197</span><span id="line-197"> this.storeFileSize = value;</span> |
| <span class="source-line-no">198</span><span id="line-198"> return this;</span> |
| <span class="source-line-no">199</span><span id="line-199"> }</span> |
| <span class="source-line-no">200</span><span id="line-200"></span> |
| <span class="source-line-no">201</span><span id="line-201"> public RegionMetricsBuilder setMemStoreSize(Size value) {</span> |
| <span class="source-line-no">202</span><span id="line-202"> this.memStoreSize = value;</span> |
| <span class="source-line-no">203</span><span id="line-203"> return this;</span> |
| <span class="source-line-no">204</span><span id="line-204"> }</span> |
| <span class="source-line-no">205</span><span id="line-205"></span> |
| <span class="source-line-no">206</span><span id="line-206"> public RegionMetricsBuilder setStoreFileIndexSize(Size value) {</span> |
| <span class="source-line-no">207</span><span id="line-207"> this.indexSize = value;</span> |
| <span class="source-line-no">208</span><span id="line-208"> return this;</span> |
| <span class="source-line-no">209</span><span id="line-209"> }</span> |
| <span class="source-line-no">210</span><span id="line-210"></span> |
| <span class="source-line-no">211</span><span id="line-211"> public RegionMetricsBuilder setStoreFileRootLevelIndexSize(Size value) {</span> |
| <span class="source-line-no">212</span><span id="line-212"> this.rootLevelIndexSize = value;</span> |
| <span class="source-line-no">213</span><span id="line-213"> return this;</span> |
| <span class="source-line-no">214</span><span id="line-214"> }</span> |
| <span class="source-line-no">215</span><span id="line-215"></span> |
| <span class="source-line-no">216</span><span id="line-216"> public RegionMetricsBuilder setStoreFileUncompressedDataIndexSize(Size value) {</span> |
| <span class="source-line-no">217</span><span id="line-217"> this.uncompressedDataIndexSize = value;</span> |
| <span class="source-line-no">218</span><span id="line-218"> return this;</span> |
| <span class="source-line-no">219</span><span id="line-219"> }</span> |
| <span class="source-line-no">220</span><span id="line-220"></span> |
| <span class="source-line-no">221</span><span id="line-221"> public RegionMetricsBuilder setBloomFilterSize(Size value) {</span> |
| <span class="source-line-no">222</span><span id="line-222"> this.bloomFilterSize = value;</span> |
| <span class="source-line-no">223</span><span id="line-223"> return this;</span> |
| <span class="source-line-no">224</span><span id="line-224"> }</span> |
| <span class="source-line-no">225</span><span id="line-225"></span> |
| <span class="source-line-no">226</span><span id="line-226"> public RegionMetricsBuilder setUncompressedStoreFileSize(Size value) {</span> |
| <span class="source-line-no">227</span><span id="line-227"> this.uncompressedStoreFileSize = value;</span> |
| <span class="source-line-no">228</span><span id="line-228"> return this;</span> |
| <span class="source-line-no">229</span><span id="line-229"> }</span> |
| <span class="source-line-no">230</span><span id="line-230"></span> |
| <span class="source-line-no">231</span><span id="line-231"> public RegionMetricsBuilder setWriteRequestCount(long value) {</span> |
| <span class="source-line-no">232</span><span id="line-232"> this.writeRequestCount = value;</span> |
| <span class="source-line-no">233</span><span id="line-233"> return this;</span> |
| <span class="source-line-no">234</span><span id="line-234"> }</span> |
| <span class="source-line-no">235</span><span id="line-235"></span> |
| <span class="source-line-no">236</span><span id="line-236"> public RegionMetricsBuilder setReadRequestCount(long value) {</span> |
| <span class="source-line-no">237</span><span id="line-237"> this.readRequestCount = value;</span> |
| <span class="source-line-no">238</span><span id="line-238"> return this;</span> |
| <span class="source-line-no">239</span><span id="line-239"> }</span> |
| <span class="source-line-no">240</span><span id="line-240"></span> |
| <span class="source-line-no">241</span><span id="line-241"> public RegionMetricsBuilder setCpRequestCount(long value) {</span> |
| <span class="source-line-no">242</span><span id="line-242"> this.cpRequestCount = value;</span> |
| <span class="source-line-no">243</span><span id="line-243"> return this;</span> |
| <span class="source-line-no">244</span><span id="line-244"> }</span> |
| <span class="source-line-no">245</span><span id="line-245"></span> |
| <span class="source-line-no">246</span><span id="line-246"> public RegionMetricsBuilder setFilteredReadRequestCount(long value) {</span> |
| <span class="source-line-no">247</span><span id="line-247"> this.filteredReadRequestCount = value;</span> |
| <span class="source-line-no">248</span><span id="line-248"> return this;</span> |
| <span class="source-line-no">249</span><span id="line-249"> }</span> |
| <span class="source-line-no">250</span><span id="line-250"></span> |
| <span class="source-line-no">251</span><span id="line-251"> public RegionMetricsBuilder setCompletedSequenceId(long value) {</span> |
| <span class="source-line-no">252</span><span id="line-252"> this.completedSequenceId = value;</span> |
| <span class="source-line-no">253</span><span id="line-253"> return this;</span> |
| <span class="source-line-no">254</span><span id="line-254"> }</span> |
| <span class="source-line-no">255</span><span id="line-255"></span> |
| <span class="source-line-no">256</span><span id="line-256"> public RegionMetricsBuilder setStoreSequenceIds(Map<byte[], Long> value) {</span> |
| <span class="source-line-no">257</span><span id="line-257"> this.storeSequenceIds = value;</span> |
| <span class="source-line-no">258</span><span id="line-258"> return this;</span> |
| <span class="source-line-no">259</span><span id="line-259"> }</span> |
| <span class="source-line-no">260</span><span id="line-260"></span> |
| <span class="source-line-no">261</span><span id="line-261"> public RegionMetricsBuilder setDataLocality(float value) {</span> |
| <span class="source-line-no">262</span><span id="line-262"> this.dataLocality = value;</span> |
| <span class="source-line-no">263</span><span id="line-263"> return this;</span> |
| <span class="source-line-no">264</span><span id="line-264"> }</span> |
| <span class="source-line-no">265</span><span id="line-265"></span> |
| <span class="source-line-no">266</span><span id="line-266"> public RegionMetricsBuilder setLastMajorCompactionTimestamp(long value) {</span> |
| <span class="source-line-no">267</span><span id="line-267"> this.lastMajorCompactionTimestamp = value;</span> |
| <span class="source-line-no">268</span><span id="line-268"> return this;</span> |
| <span class="source-line-no">269</span><span id="line-269"> }</span> |
| <span class="source-line-no">270</span><span id="line-270"></span> |
| <span class="source-line-no">271</span><span id="line-271"> public RegionMetricsBuilder setDataLocalityForSsd(float value) {</span> |
| <span class="source-line-no">272</span><span id="line-272"> this.dataLocalityForSsd = value;</span> |
| <span class="source-line-no">273</span><span id="line-273"> return this;</span> |
| <span class="source-line-no">274</span><span id="line-274"> }</span> |
| <span class="source-line-no">275</span><span id="line-275"></span> |
| <span class="source-line-no">276</span><span id="line-276"> public RegionMetricsBuilder setBlocksLocalWeight(long value) {</span> |
| <span class="source-line-no">277</span><span id="line-277"> this.blocksLocalWeight = value;</span> |
| <span class="source-line-no">278</span><span id="line-278"> return this;</span> |
| <span class="source-line-no">279</span><span id="line-279"> }</span> |
| <span class="source-line-no">280</span><span id="line-280"></span> |
| <span class="source-line-no">281</span><span id="line-281"> public RegionMetricsBuilder setBlocksLocalWithSsdWeight(long value) {</span> |
| <span class="source-line-no">282</span><span id="line-282"> this.blocksLocalWithSsdWeight = value;</span> |
| <span class="source-line-no">283</span><span id="line-283"> return this;</span> |
| <span class="source-line-no">284</span><span id="line-284"> }</span> |
| <span class="source-line-no">285</span><span id="line-285"></span> |
| <span class="source-line-no">286</span><span id="line-286"> public RegionMetricsBuilder setBlocksTotalWeight(long value) {</span> |
| <span class="source-line-no">287</span><span id="line-287"> this.blocksTotalWeight = value;</span> |
| <span class="source-line-no">288</span><span id="line-288"> return this;</span> |
| <span class="source-line-no">289</span><span id="line-289"> }</span> |
| <span class="source-line-no">290</span><span id="line-290"></span> |
| <span class="source-line-no">291</span><span id="line-291"> public RegionMetricsBuilder setCompactionState(CompactionState compactionState) {</span> |
| <span class="source-line-no">292</span><span id="line-292"> this.compactionState = compactionState;</span> |
| <span class="source-line-no">293</span><span id="line-293"> return this;</span> |
| <span class="source-line-no">294</span><span id="line-294"> }</span> |
| <span class="source-line-no">295</span><span id="line-295"></span> |
| <span class="source-line-no">296</span><span id="line-296"> public RegionMetricsBuilder setRegionSizeMB(Size value) {</span> |
| <span class="source-line-no">297</span><span id="line-297"> this.regionSizeMB = value;</span> |
| <span class="source-line-no">298</span><span id="line-298"> return this;</span> |
| <span class="source-line-no">299</span><span id="line-299"> }</span> |
| <span class="source-line-no">300</span><span id="line-300"></span> |
| <span class="source-line-no">301</span><span id="line-301"> public RegionMetricsBuilder setCurrentRegionCachedRatio(float value) {</span> |
| <span class="source-line-no">302</span><span id="line-302"> this.currentRegionCachedRatio = value;</span> |
| <span class="source-line-no">303</span><span id="line-303"> return this;</span> |
| <span class="source-line-no">304</span><span id="line-304"> }</span> |
| <span class="source-line-no">305</span><span id="line-305"></span> |
| <span class="source-line-no">306</span><span id="line-306"> public RegionMetrics build() {</span> |
| <span class="source-line-no">307</span><span id="line-307"> return new RegionMetricsImpl(name, storeCount, storeFileCount, storeRefCount,</span> |
| <span class="source-line-no">308</span><span id="line-308"> maxCompactedStoreFileRefCount, compactingCellCount, compactedCellCount, storeFileSize,</span> |
| <span class="source-line-no">309</span><span id="line-309"> memStoreSize, indexSize, rootLevelIndexSize, uncompressedDataIndexSize, bloomFilterSize,</span> |
| <span class="source-line-no">310</span><span id="line-310"> uncompressedStoreFileSize, writeRequestCount, readRequestCount, cpRequestCount,</span> |
| <span class="source-line-no">311</span><span id="line-311"> filteredReadRequestCount, completedSequenceId, storeSequenceIds, dataLocality,</span> |
| <span class="source-line-no">312</span><span id="line-312"> lastMajorCompactionTimestamp, dataLocalityForSsd, blocksLocalWeight, blocksLocalWithSsdWeight,</span> |
| <span class="source-line-no">313</span><span id="line-313"> blocksTotalWeight, compactionState, regionSizeMB, currentRegionCachedRatio);</span> |
| <span class="source-line-no">314</span><span id="line-314"> }</span> |
| <span class="source-line-no">315</span><span id="line-315"></span> |
| <span class="source-line-no">316</span><span id="line-316"> private static class RegionMetricsImpl implements RegionMetrics {</span> |
| <span class="source-line-no">317</span><span id="line-317"> private final byte[] name;</span> |
| <span class="source-line-no">318</span><span id="line-318"> private final int storeCount;</span> |
| <span class="source-line-no">319</span><span id="line-319"> private final int storeFileCount;</span> |
| <span class="source-line-no">320</span><span id="line-320"> private final int storeRefCount;</span> |
| <span class="source-line-no">321</span><span id="line-321"> private final int maxCompactedStoreFileRefCount;</span> |
| <span class="source-line-no">322</span><span id="line-322"> private final long compactingCellCount;</span> |
| <span class="source-line-no">323</span><span id="line-323"> private final long compactedCellCount;</span> |
| <span class="source-line-no">324</span><span id="line-324"> private final Size storeFileSize;</span> |
| <span class="source-line-no">325</span><span id="line-325"> private final Size memStoreSize;</span> |
| <span class="source-line-no">326</span><span id="line-326"> private final Size indexSize;</span> |
| <span class="source-line-no">327</span><span id="line-327"> private final Size rootLevelIndexSize;</span> |
| <span class="source-line-no">328</span><span id="line-328"> private final Size uncompressedDataIndexSize;</span> |
| <span class="source-line-no">329</span><span id="line-329"> private final Size bloomFilterSize;</span> |
| <span class="source-line-no">330</span><span id="line-330"> private final Size uncompressedStoreFileSize;</span> |
| <span class="source-line-no">331</span><span id="line-331"> private final long writeRequestCount;</span> |
| <span class="source-line-no">332</span><span id="line-332"> private final long readRequestCount;</span> |
| <span class="source-line-no">333</span><span id="line-333"> private final long cpRequestCount;</span> |
| <span class="source-line-no">334</span><span id="line-334"> private final long filteredReadRequestCount;</span> |
| <span class="source-line-no">335</span><span id="line-335"> private final long completedSequenceId;</span> |
| <span class="source-line-no">336</span><span id="line-336"> private final Map<byte[], Long> storeSequenceIds;</span> |
| <span class="source-line-no">337</span><span id="line-337"> private final float dataLocality;</span> |
| <span class="source-line-no">338</span><span id="line-338"> private final long lastMajorCompactionTimestamp;</span> |
| <span class="source-line-no">339</span><span id="line-339"> private final float dataLocalityForSsd;</span> |
| <span class="source-line-no">340</span><span id="line-340"> private final long blocksLocalWeight;</span> |
| <span class="source-line-no">341</span><span id="line-341"> private final long blocksLocalWithSsdWeight;</span> |
| <span class="source-line-no">342</span><span id="line-342"> private final long blocksTotalWeight;</span> |
| <span class="source-line-no">343</span><span id="line-343"> private final CompactionState compactionState;</span> |
| <span class="source-line-no">344</span><span id="line-344"> private final Size regionSizeMB;</span> |
| <span class="source-line-no">345</span><span id="line-345"> private final float currentRegionCachedRatio;</span> |
| <span class="source-line-no">346</span><span id="line-346"></span> |
| <span class="source-line-no">347</span><span id="line-347"> RegionMetricsImpl(byte[] name, int storeCount, int storeFileCount, int storeRefCount,</span> |
| <span class="source-line-no">348</span><span id="line-348"> int maxCompactedStoreFileRefCount, final long compactingCellCount, long compactedCellCount,</span> |
| <span class="source-line-no">349</span><span id="line-349"> Size storeFileSize, Size memStoreSize, Size indexSize, Size rootLevelIndexSize,</span> |
| <span class="source-line-no">350</span><span id="line-350"> Size uncompressedDataIndexSize, Size bloomFilterSize, Size uncompressedStoreFileSize,</span> |
| <span class="source-line-no">351</span><span id="line-351"> long writeRequestCount, long readRequestCount, long cpRequestCount,</span> |
| <span class="source-line-no">352</span><span id="line-352"> long filteredReadRequestCount, long completedSequenceId, Map<byte[], Long> storeSequenceIds,</span> |
| <span class="source-line-no">353</span><span id="line-353"> float dataLocality, long lastMajorCompactionTimestamp, float dataLocalityForSsd,</span> |
| <span class="source-line-no">354</span><span id="line-354"> long blocksLocalWeight, long blocksLocalWithSsdWeight, long blocksTotalWeight,</span> |
| <span class="source-line-no">355</span><span id="line-355"> CompactionState compactionState, Size regionSizeMB, float currentRegionCachedRatio) {</span> |
| <span class="source-line-no">356</span><span id="line-356"> this.name = Preconditions.checkNotNull(name);</span> |
| <span class="source-line-no">357</span><span id="line-357"> this.storeCount = storeCount;</span> |
| <span class="source-line-no">358</span><span id="line-358"> this.storeFileCount = storeFileCount;</span> |
| <span class="source-line-no">359</span><span id="line-359"> this.storeRefCount = storeRefCount;</span> |
| <span class="source-line-no">360</span><span id="line-360"> this.maxCompactedStoreFileRefCount = maxCompactedStoreFileRefCount;</span> |
| <span class="source-line-no">361</span><span id="line-361"> this.compactingCellCount = compactingCellCount;</span> |
| <span class="source-line-no">362</span><span id="line-362"> this.compactedCellCount = compactedCellCount;</span> |
| <span class="source-line-no">363</span><span id="line-363"> this.storeFileSize = Preconditions.checkNotNull(storeFileSize);</span> |
| <span class="source-line-no">364</span><span id="line-364"> this.memStoreSize = Preconditions.checkNotNull(memStoreSize);</span> |
| <span class="source-line-no">365</span><span id="line-365"> this.indexSize = Preconditions.checkNotNull(indexSize);</span> |
| <span class="source-line-no">366</span><span id="line-366"> this.rootLevelIndexSize = Preconditions.checkNotNull(rootLevelIndexSize);</span> |
| <span class="source-line-no">367</span><span id="line-367"> this.uncompressedDataIndexSize = Preconditions.checkNotNull(uncompressedDataIndexSize);</span> |
| <span class="source-line-no">368</span><span id="line-368"> this.bloomFilterSize = Preconditions.checkNotNull(bloomFilterSize);</span> |
| <span class="source-line-no">369</span><span id="line-369"> this.uncompressedStoreFileSize = Preconditions.checkNotNull(uncompressedStoreFileSize);</span> |
| <span class="source-line-no">370</span><span id="line-370"> this.writeRequestCount = writeRequestCount;</span> |
| <span class="source-line-no">371</span><span id="line-371"> this.readRequestCount = readRequestCount;</span> |
| <span class="source-line-no">372</span><span id="line-372"> this.cpRequestCount = cpRequestCount;</span> |
| <span class="source-line-no">373</span><span id="line-373"> this.filteredReadRequestCount = filteredReadRequestCount;</span> |
| <span class="source-line-no">374</span><span id="line-374"> this.completedSequenceId = completedSequenceId;</span> |
| <span class="source-line-no">375</span><span id="line-375"> this.storeSequenceIds = Preconditions.checkNotNull(storeSequenceIds);</span> |
| <span class="source-line-no">376</span><span id="line-376"> this.dataLocality = dataLocality;</span> |
| <span class="source-line-no">377</span><span id="line-377"> this.lastMajorCompactionTimestamp = lastMajorCompactionTimestamp;</span> |
| <span class="source-line-no">378</span><span id="line-378"> this.dataLocalityForSsd = dataLocalityForSsd;</span> |
| <span class="source-line-no">379</span><span id="line-379"> this.blocksLocalWeight = blocksLocalWeight;</span> |
| <span class="source-line-no">380</span><span id="line-380"> this.blocksLocalWithSsdWeight = blocksLocalWithSsdWeight;</span> |
| <span class="source-line-no">381</span><span id="line-381"> this.blocksTotalWeight = blocksTotalWeight;</span> |
| <span class="source-line-no">382</span><span id="line-382"> this.compactionState = compactionState;</span> |
| <span class="source-line-no">383</span><span id="line-383"> this.regionSizeMB = regionSizeMB;</span> |
| <span class="source-line-no">384</span><span id="line-384"> this.currentRegionCachedRatio = currentRegionCachedRatio;</span> |
| <span class="source-line-no">385</span><span id="line-385"> }</span> |
| <span class="source-line-no">386</span><span id="line-386"></span> |
| <span class="source-line-no">387</span><span id="line-387"> @Override</span> |
| <span class="source-line-no">388</span><span id="line-388"> public byte[] getRegionName() {</span> |
| <span class="source-line-no">389</span><span id="line-389"> return name;</span> |
| <span class="source-line-no">390</span><span id="line-390"> }</span> |
| <span class="source-line-no">391</span><span id="line-391"></span> |
| <span class="source-line-no">392</span><span id="line-392"> @Override</span> |
| <span class="source-line-no">393</span><span id="line-393"> public int getStoreCount() {</span> |
| <span class="source-line-no">394</span><span id="line-394"> return storeCount;</span> |
| <span class="source-line-no">395</span><span id="line-395"> }</span> |
| <span class="source-line-no">396</span><span id="line-396"></span> |
| <span class="source-line-no">397</span><span id="line-397"> @Override</span> |
| <span class="source-line-no">398</span><span id="line-398"> public int getStoreFileCount() {</span> |
| <span class="source-line-no">399</span><span id="line-399"> return storeFileCount;</span> |
| <span class="source-line-no">400</span><span id="line-400"> }</span> |
| <span class="source-line-no">401</span><span id="line-401"></span> |
| <span class="source-line-no">402</span><span id="line-402"> @Override</span> |
| <span class="source-line-no">403</span><span id="line-403"> public int getStoreRefCount() {</span> |
| <span class="source-line-no">404</span><span id="line-404"> return storeRefCount;</span> |
| <span class="source-line-no">405</span><span id="line-405"> }</span> |
| <span class="source-line-no">406</span><span id="line-406"></span> |
| <span class="source-line-no">407</span><span id="line-407"> @Override</span> |
| <span class="source-line-no">408</span><span id="line-408"> public int getMaxCompactedStoreFileRefCount() {</span> |
| <span class="source-line-no">409</span><span id="line-409"> return maxCompactedStoreFileRefCount;</span> |
| <span class="source-line-no">410</span><span id="line-410"> }</span> |
| <span class="source-line-no">411</span><span id="line-411"></span> |
| <span class="source-line-no">412</span><span id="line-412"> @Override</span> |
| <span class="source-line-no">413</span><span id="line-413"> public Size getStoreFileSize() {</span> |
| <span class="source-line-no">414</span><span id="line-414"> return storeFileSize;</span> |
| <span class="source-line-no">415</span><span id="line-415"> }</span> |
| <span class="source-line-no">416</span><span id="line-416"></span> |
| <span class="source-line-no">417</span><span id="line-417"> @Override</span> |
| <span class="source-line-no">418</span><span id="line-418"> public Size getMemStoreSize() {</span> |
| <span class="source-line-no">419</span><span id="line-419"> return memStoreSize;</span> |
| <span class="source-line-no">420</span><span id="line-420"> }</span> |
| <span class="source-line-no">421</span><span id="line-421"></span> |
| <span class="source-line-no">422</span><span id="line-422"> @Override</span> |
| <span class="source-line-no">423</span><span id="line-423"> public long getReadRequestCount() {</span> |
| <span class="source-line-no">424</span><span id="line-424"> return readRequestCount;</span> |
| <span class="source-line-no">425</span><span id="line-425"> }</span> |
| <span class="source-line-no">426</span><span id="line-426"></span> |
| <span class="source-line-no">427</span><span id="line-427"> @Override</span> |
| <span class="source-line-no">428</span><span id="line-428"> public long getCpRequestCount() {</span> |
| <span class="source-line-no">429</span><span id="line-429"> return cpRequestCount;</span> |
| <span class="source-line-no">430</span><span id="line-430"> }</span> |
| <span class="source-line-no">431</span><span id="line-431"></span> |
| <span class="source-line-no">432</span><span id="line-432"> @Override</span> |
| <span class="source-line-no">433</span><span id="line-433"> public long getFilteredReadRequestCount() {</span> |
| <span class="source-line-no">434</span><span id="line-434"> return filteredReadRequestCount;</span> |
| <span class="source-line-no">435</span><span id="line-435"> }</span> |
| <span class="source-line-no">436</span><span id="line-436"></span> |
| <span class="source-line-no">437</span><span id="line-437"> @Override</span> |
| <span class="source-line-no">438</span><span id="line-438"> public long getWriteRequestCount() {</span> |
| <span class="source-line-no">439</span><span id="line-439"> return writeRequestCount;</span> |
| <span class="source-line-no">440</span><span id="line-440"> }</span> |
| <span class="source-line-no">441</span><span id="line-441"></span> |
| <span class="source-line-no">442</span><span id="line-442"> @Override</span> |
| <span class="source-line-no">443</span><span id="line-443"> public Size getStoreFileIndexSize() {</span> |
| <span class="source-line-no">444</span><span id="line-444"> return indexSize;</span> |
| <span class="source-line-no">445</span><span id="line-445"> }</span> |
| <span class="source-line-no">446</span><span id="line-446"></span> |
| <span class="source-line-no">447</span><span id="line-447"> @Override</span> |
| <span class="source-line-no">448</span><span id="line-448"> public Size getStoreFileRootLevelIndexSize() {</span> |
| <span class="source-line-no">449</span><span id="line-449"> return rootLevelIndexSize;</span> |
| <span class="source-line-no">450</span><span id="line-450"> }</span> |
| <span class="source-line-no">451</span><span id="line-451"></span> |
| <span class="source-line-no">452</span><span id="line-452"> @Override</span> |
| <span class="source-line-no">453</span><span id="line-453"> public Size getStoreFileUncompressedDataIndexSize() {</span> |
| <span class="source-line-no">454</span><span id="line-454"> return uncompressedDataIndexSize;</span> |
| <span class="source-line-no">455</span><span id="line-455"> }</span> |
| <span class="source-line-no">456</span><span id="line-456"></span> |
| <span class="source-line-no">457</span><span id="line-457"> @Override</span> |
| <span class="source-line-no">458</span><span id="line-458"> public Size getBloomFilterSize() {</span> |
| <span class="source-line-no">459</span><span id="line-459"> return bloomFilterSize;</span> |
| <span class="source-line-no">460</span><span id="line-460"> }</span> |
| <span class="source-line-no">461</span><span id="line-461"></span> |
| <span class="source-line-no">462</span><span id="line-462"> @Override</span> |
| <span class="source-line-no">463</span><span id="line-463"> public long getCompactingCellCount() {</span> |
| <span class="source-line-no">464</span><span id="line-464"> return compactingCellCount;</span> |
| <span class="source-line-no">465</span><span id="line-465"> }</span> |
| <span class="source-line-no">466</span><span id="line-466"></span> |
| <span class="source-line-no">467</span><span id="line-467"> @Override</span> |
| <span class="source-line-no">468</span><span id="line-468"> public long getCompactedCellCount() {</span> |
| <span class="source-line-no">469</span><span id="line-469"> return compactedCellCount;</span> |
| <span class="source-line-no">470</span><span id="line-470"> }</span> |
| <span class="source-line-no">471</span><span id="line-471"></span> |
| <span class="source-line-no">472</span><span id="line-472"> @Override</span> |
| <span class="source-line-no">473</span><span id="line-473"> public long getCompletedSequenceId() {</span> |
| <span class="source-line-no">474</span><span id="line-474"> return completedSequenceId;</span> |
| <span class="source-line-no">475</span><span id="line-475"> }</span> |
| <span class="source-line-no">476</span><span id="line-476"></span> |
| <span class="source-line-no">477</span><span id="line-477"> @Override</span> |
| <span class="source-line-no">478</span><span id="line-478"> public Map<byte[], Long> getStoreSequenceId() {</span> |
| <span class="source-line-no">479</span><span id="line-479"> return Collections.unmodifiableMap(storeSequenceIds);</span> |
| <span class="source-line-no">480</span><span id="line-480"> }</span> |
| <span class="source-line-no">481</span><span id="line-481"></span> |
| <span class="source-line-no">482</span><span id="line-482"> @Override</span> |
| <span class="source-line-no">483</span><span id="line-483"> public Size getUncompressedStoreFileSize() {</span> |
| <span class="source-line-no">484</span><span id="line-484"> return uncompressedStoreFileSize;</span> |
| <span class="source-line-no">485</span><span id="line-485"> }</span> |
| <span class="source-line-no">486</span><span id="line-486"></span> |
| <span class="source-line-no">487</span><span id="line-487"> @Override</span> |
| <span class="source-line-no">488</span><span id="line-488"> public float getDataLocality() {</span> |
| <span class="source-line-no">489</span><span id="line-489"> return dataLocality;</span> |
| <span class="source-line-no">490</span><span id="line-490"> }</span> |
| <span class="source-line-no">491</span><span id="line-491"></span> |
| <span class="source-line-no">492</span><span id="line-492"> @Override</span> |
| <span class="source-line-no">493</span><span id="line-493"> public long getLastMajorCompactionTimestamp() {</span> |
| <span class="source-line-no">494</span><span id="line-494"> return lastMajorCompactionTimestamp;</span> |
| <span class="source-line-no">495</span><span id="line-495"> }</span> |
| <span class="source-line-no">496</span><span id="line-496"></span> |
| <span class="source-line-no">497</span><span id="line-497"> @Override</span> |
| <span class="source-line-no">498</span><span id="line-498"> public float getDataLocalityForSsd() {</span> |
| <span class="source-line-no">499</span><span id="line-499"> return dataLocalityForSsd;</span> |
| <span class="source-line-no">500</span><span id="line-500"> }</span> |
| <span class="source-line-no">501</span><span id="line-501"></span> |
| <span class="source-line-no">502</span><span id="line-502"> @Override</span> |
| <span class="source-line-no">503</span><span id="line-503"> public long getBlocksLocalWeight() {</span> |
| <span class="source-line-no">504</span><span id="line-504"> return blocksLocalWeight;</span> |
| <span class="source-line-no">505</span><span id="line-505"> }</span> |
| <span class="source-line-no">506</span><span id="line-506"></span> |
| <span class="source-line-no">507</span><span id="line-507"> @Override</span> |
| <span class="source-line-no">508</span><span id="line-508"> public long getBlocksLocalWithSsdWeight() {</span> |
| <span class="source-line-no">509</span><span id="line-509"> return blocksLocalWithSsdWeight;</span> |
| <span class="source-line-no">510</span><span id="line-510"> }</span> |
| <span class="source-line-no">511</span><span id="line-511"></span> |
| <span class="source-line-no">512</span><span id="line-512"> @Override</span> |
| <span class="source-line-no">513</span><span id="line-513"> public long getBlocksTotalWeight() {</span> |
| <span class="source-line-no">514</span><span id="line-514"> return blocksTotalWeight;</span> |
| <span class="source-line-no">515</span><span id="line-515"> }</span> |
| <span class="source-line-no">516</span><span id="line-516"></span> |
| <span class="source-line-no">517</span><span id="line-517"> @Override</span> |
| <span class="source-line-no">518</span><span id="line-518"> public CompactionState getCompactionState() {</span> |
| <span class="source-line-no">519</span><span id="line-519"> return compactionState;</span> |
| <span class="source-line-no">520</span><span id="line-520"> }</span> |
| <span class="source-line-no">521</span><span id="line-521"></span> |
| <span class="source-line-no">522</span><span id="line-522"> @Override</span> |
| <span class="source-line-no">523</span><span id="line-523"> public Size getRegionSizeMB() {</span> |
| <span class="source-line-no">524</span><span id="line-524"> return regionSizeMB;</span> |
| <span class="source-line-no">525</span><span id="line-525"> }</span> |
| <span class="source-line-no">526</span><span id="line-526"></span> |
| <span class="source-line-no">527</span><span id="line-527"> @Override</span> |
| <span class="source-line-no">528</span><span id="line-528"> public float getCurrentRegionCachedRatio() {</span> |
| <span class="source-line-no">529</span><span id="line-529"> return currentRegionCachedRatio;</span> |
| <span class="source-line-no">530</span><span id="line-530"> }</span> |
| <span class="source-line-no">531</span><span id="line-531"></span> |
| <span class="source-line-no">532</span><span id="line-532"> @Override</span> |
| <span class="source-line-no">533</span><span id="line-533"> public String toString() {</span> |
| <span class="source-line-no">534</span><span id="line-534"> StringBuilder sb =</span> |
| <span class="source-line-no">535</span><span id="line-535"> Strings.appendKeyValue(new StringBuilder(), "storeCount", this.getStoreCount());</span> |
| <span class="source-line-no">536</span><span id="line-536"> Strings.appendKeyValue(sb, "storeFileCount", this.getStoreFileCount());</span> |
| <span class="source-line-no">537</span><span id="line-537"> Strings.appendKeyValue(sb, "storeRefCount", this.getStoreRefCount());</span> |
| <span class="source-line-no">538</span><span id="line-538"> Strings.appendKeyValue(sb, "maxCompactedStoreFileRefCount",</span> |
| <span class="source-line-no">539</span><span id="line-539"> this.getMaxCompactedStoreFileRefCount());</span> |
| <span class="source-line-no">540</span><span id="line-540"> Strings.appendKeyValue(sb, "uncompressedStoreFileSize", this.getUncompressedStoreFileSize());</span> |
| <span class="source-line-no">541</span><span id="line-541"> Strings.appendKeyValue(sb, "lastMajorCompactionTimestamp",</span> |
| <span class="source-line-no">542</span><span id="line-542"> this.getLastMajorCompactionTimestamp());</span> |
| <span class="source-line-no">543</span><span id="line-543"> Strings.appendKeyValue(sb, "storeFileSize", this.getStoreFileSize());</span> |
| <span class="source-line-no">544</span><span id="line-544"> if (this.getUncompressedStoreFileSize().get() != 0) {</span> |
| <span class="source-line-no">545</span><span id="line-545"> Strings.appendKeyValue(sb, "compressionRatio",</span> |
| <span class="source-line-no">546</span><span id="line-546"> String.format("%.4f", (float) this.getStoreFileSize().get(Size.Unit.MEGABYTE)</span> |
| <span class="source-line-no">547</span><span id="line-547"> / (float) this.getUncompressedStoreFileSize().get(Size.Unit.MEGABYTE)));</span> |
| <span class="source-line-no">548</span><span id="line-548"> }</span> |
| <span class="source-line-no">549</span><span id="line-549"> Strings.appendKeyValue(sb, "memStoreSize", this.getMemStoreSize());</span> |
| <span class="source-line-no">550</span><span id="line-550"> Strings.appendKeyValue(sb, "readRequestCount", this.getReadRequestCount());</span> |
| <span class="source-line-no">551</span><span id="line-551"> Strings.appendKeyValue(sb, "cpRequestCount", this.getCpRequestCount());</span> |
| <span class="source-line-no">552</span><span id="line-552"> Strings.appendKeyValue(sb, "writeRequestCount", this.getWriteRequestCount());</span> |
| <span class="source-line-no">553</span><span id="line-553"> Strings.appendKeyValue(sb, "rootLevelIndexSize", this.getStoreFileRootLevelIndexSize());</span> |
| <span class="source-line-no">554</span><span id="line-554"> Strings.appendKeyValue(sb, "uncompressedDataIndexSize",</span> |
| <span class="source-line-no">555</span><span id="line-555"> this.getStoreFileUncompressedDataIndexSize());</span> |
| <span class="source-line-no">556</span><span id="line-556"> Strings.appendKeyValue(sb, "bloomFilterSize", this.getBloomFilterSize());</span> |
| <span class="source-line-no">557</span><span id="line-557"> Strings.appendKeyValue(sb, "compactingCellCount", this.getCompactingCellCount());</span> |
| <span class="source-line-no">558</span><span id="line-558"> Strings.appendKeyValue(sb, "compactedCellCount", this.getCompactedCellCount());</span> |
| <span class="source-line-no">559</span><span id="line-559"> float compactionProgressPct = Float.NaN;</span> |
| <span class="source-line-no">560</span><span id="line-560"> if (this.getCompactingCellCount() > 0) {</span> |
| <span class="source-line-no">561</span><span id="line-561"> compactionProgressPct =</span> |
| <span class="source-line-no">562</span><span id="line-562"> ((float) this.getCompactedCellCount() / (float) this.getCompactingCellCount());</span> |
| <span class="source-line-no">563</span><span id="line-563"> }</span> |
| <span class="source-line-no">564</span><span id="line-564"> Strings.appendKeyValue(sb, "compactionProgressPct", compactionProgressPct);</span> |
| <span class="source-line-no">565</span><span id="line-565"> Strings.appendKeyValue(sb, "completedSequenceId", this.getCompletedSequenceId());</span> |
| <span class="source-line-no">566</span><span id="line-566"> Strings.appendKeyValue(sb, "dataLocality", this.getDataLocality());</span> |
| <span class="source-line-no">567</span><span id="line-567"> Strings.appendKeyValue(sb, "dataLocalityForSsd", this.getDataLocalityForSsd());</span> |
| <span class="source-line-no">568</span><span id="line-568"> Strings.appendKeyValue(sb, "blocksLocalWeight", blocksLocalWeight);</span> |
| <span class="source-line-no">569</span><span id="line-569"> Strings.appendKeyValue(sb, "blocksLocalWithSsdWeight", blocksLocalWithSsdWeight);</span> |
| <span class="source-line-no">570</span><span id="line-570"> Strings.appendKeyValue(sb, "blocksTotalWeight", blocksTotalWeight);</span> |
| <span class="source-line-no">571</span><span id="line-571"> Strings.appendKeyValue(sb, "compactionState", compactionState);</span> |
| <span class="source-line-no">572</span><span id="line-572"> Strings.appendKeyValue(sb, "regionSizeMB", regionSizeMB);</span> |
| <span class="source-line-no">573</span><span id="line-573"> Strings.appendKeyValue(sb, "currentRegionCachedRatio", currentRegionCachedRatio);</span> |
| <span class="source-line-no">574</span><span id="line-574"> return sb.toString();</span> |
| <span class="source-line-no">575</span><span id="line-575"> }</span> |
| <span class="source-line-no">576</span><span id="line-576"> }</span> |
| <span class="source-line-no">577</span><span id="line-577"></span> |
| <span class="source-line-no">578</span><span id="line-578">}</span> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| </pre> |
| </div> |
| </main> |
| </body> |
| </html> |