| <!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.client, class: ColumnFamilyDescriptorBuilder"> |
| <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.client;</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.io.IOException;</span> |
| <span class="source-line-no">021</span><span id="line-21">import java.util.Collections;</span> |
| <span class="source-line-no">022</span><span id="line-22">import java.util.HashMap;</span> |
| <span class="source-line-no">023</span><span id="line-23">import java.util.HashSet;</span> |
| <span class="source-line-no">024</span><span id="line-24">import java.util.Map;</span> |
| <span class="source-line-no">025</span><span id="line-25">import java.util.Set;</span> |
| <span class="source-line-no">026</span><span id="line-26">import java.util.function.Function;</span> |
| <span class="source-line-no">027</span><span id="line-27">import org.apache.hadoop.hbase.HConstants;</span> |
| <span class="source-line-no">028</span><span id="line-28">import org.apache.hadoop.hbase.KeepDeletedCells;</span> |
| <span class="source-line-no">029</span><span id="line-29">import org.apache.hadoop.hbase.MemoryCompactionPolicy;</span> |
| <span class="source-line-no">030</span><span id="line-30">import org.apache.hadoop.hbase.exceptions.DeserializationException;</span> |
| <span class="source-line-no">031</span><span id="line-31">import org.apache.hadoop.hbase.exceptions.HBaseException;</span> |
| <span class="source-line-no">032</span><span id="line-32">import org.apache.hadoop.hbase.io.compress.Compression;</span> |
| <span class="source-line-no">033</span><span id="line-33">import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;</span> |
| <span class="source-line-no">034</span><span id="line-34">import org.apache.hadoop.hbase.io.encoding.IndexBlockEncoding;</span> |
| <span class="source-line-no">035</span><span id="line-35">import org.apache.hadoop.hbase.regionserver.BloomType;</span> |
| <span class="source-line-no">036</span><span id="line-36">import org.apache.hadoop.hbase.util.Bytes;</span> |
| <span class="source-line-no">037</span><span id="line-37">import org.apache.hadoop.hbase.util.PrettyPrinter;</span> |
| <span class="source-line-no">038</span><span id="line-38">import org.apache.hadoop.hbase.util.PrettyPrinter.Unit;</span> |
| <span class="source-line-no">039</span><span id="line-39">import org.apache.yetus.audience.InterfaceAudience;</span> |
| <span class="source-line-no">040</span><span id="line-40"></span> |
| <span class="source-line-no">041</span><span id="line-41">import org.apache.hbase.thirdparty.com.google.common.base.Preconditions;</span> |
| <span class="source-line-no">042</span><span id="line-42"></span> |
| <span class="source-line-no">043</span><span id="line-43">import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;</span> |
| <span class="source-line-no">044</span><span id="line-44">import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ColumnFamilySchema;</span> |
| <span class="source-line-no">045</span><span id="line-45"></span> |
| <span class="source-line-no">046</span><span id="line-46">@InterfaceAudience.Public</span> |
| <span class="source-line-no">047</span><span id="line-47">public class ColumnFamilyDescriptorBuilder {</span> |
| <span class="source-line-no">048</span><span id="line-48"> // For future backward compatibility</span> |
| <span class="source-line-no">049</span><span id="line-49"></span> |
| <span class="source-line-no">050</span><span id="line-50"> // Version 3 was when column names become byte arrays and when we picked up</span> |
| <span class="source-line-no">051</span><span id="line-51"> // Time-to-live feature. Version 4 was when we moved to byte arrays, HBASE-82.</span> |
| <span class="source-line-no">052</span><span id="line-52"> // Version 5 was when bloom filter descriptors were removed.</span> |
| <span class="source-line-no">053</span><span id="line-53"> // Version 6 adds metadata as a map where keys and values are byte[].</span> |
| <span class="source-line-no">054</span><span id="line-54"> // Version 7 -- add new compression and hfile blocksize to HColumnDescriptor (HBASE-1217)</span> |
| <span class="source-line-no">055</span><span id="line-55"> // Version 8 -- reintroduction of bloom filters, changed from boolean to enum</span> |
| <span class="source-line-no">056</span><span id="line-56"> // Version 9 -- add data block encoding</span> |
| <span class="source-line-no">057</span><span id="line-57"> // Version 10 -- change metadata to standard type.</span> |
| <span class="source-line-no">058</span><span id="line-58"> // Version 11 -- add column family level configuration.</span> |
| <span class="source-line-no">059</span><span id="line-59"> private static final byte COLUMN_DESCRIPTOR_VERSION = (byte) 11;</span> |
| <span class="source-line-no">060</span><span id="line-60"></span> |
| <span class="source-line-no">061</span><span id="line-61"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">062</span><span id="line-62"> public static final String IN_MEMORY_COMPACTION = "IN_MEMORY_COMPACTION";</span> |
| <span class="source-line-no">063</span><span id="line-63"> private static final Bytes IN_MEMORY_COMPACTION_BYTES =</span> |
| <span class="source-line-no">064</span><span id="line-64"> new Bytes(Bytes.toBytes(IN_MEMORY_COMPACTION));</span> |
| <span class="source-line-no">065</span><span id="line-65"></span> |
| <span class="source-line-no">066</span><span id="line-66"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">067</span><span id="line-67"> public static final String IN_MEMORY = HConstants.IN_MEMORY;</span> |
| <span class="source-line-no">068</span><span id="line-68"> private static final Bytes IN_MEMORY_BYTES = new Bytes(Bytes.toBytes(IN_MEMORY));</span> |
| <span class="source-line-no">069</span><span id="line-69"></span> |
| <span class="source-line-no">070</span><span id="line-70"> // These constants are used as FileInfo keys</span> |
| <span class="source-line-no">071</span><span id="line-71"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">072</span><span id="line-72"> public static final String COMPRESSION = "COMPRESSION";</span> |
| <span class="source-line-no">073</span><span id="line-73"> private static final Bytes COMPRESSION_BYTES = new Bytes(Bytes.toBytes(COMPRESSION));</span> |
| <span class="source-line-no">074</span><span id="line-74"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">075</span><span id="line-75"> public static final String COMPRESSION_COMPACT = "COMPRESSION_COMPACT";</span> |
| <span class="source-line-no">076</span><span id="line-76"> private static final Bytes COMPRESSION_COMPACT_BYTES =</span> |
| <span class="source-line-no">077</span><span id="line-77"> new Bytes(Bytes.toBytes(COMPRESSION_COMPACT));</span> |
| <span class="source-line-no">078</span><span id="line-78"> public static final String COMPRESSION_COMPACT_MAJOR = "COMPRESSION_COMPACT_MAJOR";</span> |
| <span class="source-line-no">079</span><span id="line-79"> private static final Bytes COMPRESSION_COMPACT_MAJOR_BYTES =</span> |
| <span class="source-line-no">080</span><span id="line-80"> new Bytes(Bytes.toBytes(COMPRESSION_COMPACT_MAJOR));</span> |
| <span class="source-line-no">081</span><span id="line-81"> public static final String COMPRESSION_COMPACT_MINOR = "COMPRESSION_COMPACT_MINOR";</span> |
| <span class="source-line-no">082</span><span id="line-82"> private static final Bytes COMPRESSION_COMPACT_MINOR_BYTES =</span> |
| <span class="source-line-no">083</span><span id="line-83"> new Bytes(Bytes.toBytes(COMPRESSION_COMPACT_MINOR));</span> |
| <span class="source-line-no">084</span><span id="line-84"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">085</span><span id="line-85"> public static final String DATA_BLOCK_ENCODING = "DATA_BLOCK_ENCODING";</span> |
| <span class="source-line-no">086</span><span id="line-86"> private static final Bytes DATA_BLOCK_ENCODING_BYTES =</span> |
| <span class="source-line-no">087</span><span id="line-87"> new Bytes(Bytes.toBytes(DATA_BLOCK_ENCODING));</span> |
| <span class="source-line-no">088</span><span id="line-88"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">089</span><span id="line-89"> public static final String INDEX_BLOCK_ENCODING = "INDEX_BLOCK_ENCODING";</span> |
| <span class="source-line-no">090</span><span id="line-90"> private static final Bytes INDEX_BLOCK_ENCODING_BYTES =</span> |
| <span class="source-line-no">091</span><span id="line-91"> new Bytes(Bytes.toBytes(INDEX_BLOCK_ENCODING));</span> |
| <span class="source-line-no">092</span><span id="line-92"> /**</span> |
| <span class="source-line-no">093</span><span id="line-93"> * Key for the BLOCKCACHE attribute. A more exact name would be CACHE_DATA_ON_READ because this</span> |
| <span class="source-line-no">094</span><span id="line-94"> * flag sets whether or not we cache DATA blocks. We always cache INDEX and BLOOM blocks; caching</span> |
| <span class="source-line-no">095</span><span id="line-95"> * these blocks cannot be disabled.</span> |
| <span class="source-line-no">096</span><span id="line-96"> */</span> |
| <span class="source-line-no">097</span><span id="line-97"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">098</span><span id="line-98"> public static final String BLOCKCACHE = "BLOCKCACHE";</span> |
| <span class="source-line-no">099</span><span id="line-99"> private static final Bytes BLOCKCACHE_BYTES = new Bytes(Bytes.toBytes(BLOCKCACHE));</span> |
| <span class="source-line-no">100</span><span id="line-100"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">101</span><span id="line-101"> public static final String CACHE_DATA_ON_WRITE = "CACHE_DATA_ON_WRITE";</span> |
| <span class="source-line-no">102</span><span id="line-102"> private static final Bytes CACHE_DATA_ON_WRITE_BYTES =</span> |
| <span class="source-line-no">103</span><span id="line-103"> new Bytes(Bytes.toBytes(CACHE_DATA_ON_WRITE));</span> |
| <span class="source-line-no">104</span><span id="line-104"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">105</span><span id="line-105"> public static final String CACHE_INDEX_ON_WRITE = "CACHE_INDEX_ON_WRITE";</span> |
| <span class="source-line-no">106</span><span id="line-106"> private static final Bytes CACHE_INDEX_ON_WRITE_BYTES =</span> |
| <span class="source-line-no">107</span><span id="line-107"> new Bytes(Bytes.toBytes(CACHE_INDEX_ON_WRITE));</span> |
| <span class="source-line-no">108</span><span id="line-108"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">109</span><span id="line-109"> public static final String CACHE_BLOOMS_ON_WRITE = "CACHE_BLOOMS_ON_WRITE";</span> |
| <span class="source-line-no">110</span><span id="line-110"> private static final Bytes CACHE_BLOOMS_ON_WRITE_BYTES =</span> |
| <span class="source-line-no">111</span><span id="line-111"> new Bytes(Bytes.toBytes(CACHE_BLOOMS_ON_WRITE));</span> |
| <span class="source-line-no">112</span><span id="line-112"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">113</span><span id="line-113"> public static final String EVICT_BLOCKS_ON_CLOSE = "EVICT_BLOCKS_ON_CLOSE";</span> |
| <span class="source-line-no">114</span><span id="line-114"> private static final Bytes EVICT_BLOCKS_ON_CLOSE_BYTES =</span> |
| <span class="source-line-no">115</span><span id="line-115"> new Bytes(Bytes.toBytes(EVICT_BLOCKS_ON_CLOSE));</span> |
| <span class="source-line-no">116</span><span id="line-116"></span> |
| <span class="source-line-no">117</span><span id="line-117"> /**</span> |
| <span class="source-line-no">118</span><span id="line-118"> * Key for the PREFETCH_BLOCKS_ON_OPEN attribute. If set, all INDEX, BLOOM, and DATA blocks of</span> |
| <span class="source-line-no">119</span><span id="line-119"> * HFiles belonging to this family will be loaded into the cache as soon as the file is opened.</span> |
| <span class="source-line-no">120</span><span id="line-120"> * These loads will not count as cache misses.</span> |
| <span class="source-line-no">121</span><span id="line-121"> */</span> |
| <span class="source-line-no">122</span><span id="line-122"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">123</span><span id="line-123"> public static final String PREFETCH_BLOCKS_ON_OPEN = "PREFETCH_BLOCKS_ON_OPEN";</span> |
| <span class="source-line-no">124</span><span id="line-124"> private static final Bytes PREFETCH_BLOCKS_ON_OPEN_BYTES =</span> |
| <span class="source-line-no">125</span><span id="line-125"> new Bytes(Bytes.toBytes(PREFETCH_BLOCKS_ON_OPEN));</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"> * Size of storefile/hfile 'blocks'. Default is {@link #DEFAULT_BLOCKSIZE}. Use smaller block</span> |
| <span class="source-line-no">129</span><span id="line-129"> * sizes for faster random-access at expense of larger indices (more memory consumption). Note</span> |
| <span class="source-line-no">130</span><span id="line-130"> * that this is a soft limit and that blocks have overhead (metadata, CRCs) so blocks will tend to</span> |
| <span class="source-line-no">131</span><span id="line-131"> * be the size specified here and then some; i.e. don't expect that setting BLOCKSIZE=4k means</span> |
| <span class="source-line-no">132</span><span id="line-132"> * hbase data will align with an SSDs 4k page accesses (TODO).</span> |
| <span class="source-line-no">133</span><span id="line-133"> */</span> |
| <span class="source-line-no">134</span><span id="line-134"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">135</span><span id="line-135"> public static final String BLOCKSIZE = "BLOCKSIZE";</span> |
| <span class="source-line-no">136</span><span id="line-136"> private static final Bytes BLOCKSIZE_BYTES = new Bytes(Bytes.toBytes(BLOCKSIZE));</span> |
| <span class="source-line-no">137</span><span id="line-137"></span> |
| <span class="source-line-no">138</span><span id="line-138"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">139</span><span id="line-139"> public static final String TTL = "TTL";</span> |
| <span class="source-line-no">140</span><span id="line-140"> private static final Bytes TTL_BYTES = new Bytes(Bytes.toBytes(TTL));</span> |
| <span class="source-line-no">141</span><span id="line-141"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">142</span><span id="line-142"> public static final String BLOOMFILTER = "BLOOMFILTER";</span> |
| <span class="source-line-no">143</span><span id="line-143"> private static final Bytes BLOOMFILTER_BYTES = new Bytes(Bytes.toBytes(BLOOMFILTER));</span> |
| <span class="source-line-no">144</span><span id="line-144"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">145</span><span id="line-145"> public static final String REPLICATION_SCOPE = "REPLICATION_SCOPE";</span> |
| <span class="source-line-no">146</span><span id="line-146"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">147</span><span id="line-147"> public static final String MAX_VERSIONS = HConstants.VERSIONS;</span> |
| <span class="source-line-no">148</span><span id="line-148"> private static final Bytes MAX_VERSIONS_BYTES = new Bytes(Bytes.toBytes(MAX_VERSIONS));</span> |
| <span class="source-line-no">149</span><span id="line-149"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">150</span><span id="line-150"> public static final String MIN_VERSIONS = "MIN_VERSIONS";</span> |
| <span class="source-line-no">151</span><span id="line-151"> private static final Bytes MIN_VERSIONS_BYTES = new Bytes(Bytes.toBytes(MIN_VERSIONS));</span> |
| <span class="source-line-no">152</span><span id="line-152"> /**</span> |
| <span class="source-line-no">153</span><span id="line-153"> * Retain all cells across flushes and compactions even if they fall behind a delete tombstone. To</span> |
| <span class="source-line-no">154</span><span id="line-154"> * see all retained cells, do a 'raw' scan; see Scan#setRaw or pass RAW =&gt; true attribute in</span> |
| <span class="source-line-no">155</span><span id="line-155"> * the shell.</span> |
| <span class="source-line-no">156</span><span id="line-156"> */</span> |
| <span class="source-line-no">157</span><span id="line-157"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">158</span><span id="line-158"> public static final String KEEP_DELETED_CELLS = "KEEP_DELETED_CELLS";</span> |
| <span class="source-line-no">159</span><span id="line-159"> private static final Bytes KEEP_DELETED_CELLS_BYTES =</span> |
| <span class="source-line-no">160</span><span id="line-160"> new Bytes(Bytes.toBytes(KEEP_DELETED_CELLS));</span> |
| <span class="source-line-no">161</span><span id="line-161"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">162</span><span id="line-162"> public static final String COMPRESS_TAGS = "COMPRESS_TAGS";</span> |
| <span class="source-line-no">163</span><span id="line-163"> private static final Bytes COMPRESS_TAGS_BYTES = new Bytes(Bytes.toBytes(COMPRESS_TAGS));</span> |
| <span class="source-line-no">164</span><span id="line-164"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">165</span><span id="line-165"> public static final String ENCRYPTION = "ENCRYPTION";</span> |
| <span class="source-line-no">166</span><span id="line-166"> private static final Bytes ENCRYPTION_BYTES = new Bytes(Bytes.toBytes(ENCRYPTION));</span> |
| <span class="source-line-no">167</span><span id="line-167"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">168</span><span id="line-168"> public static final String ENCRYPTION_KEY = "ENCRYPTION_KEY";</span> |
| <span class="source-line-no">169</span><span id="line-169"> private static final Bytes ENCRYPTION_KEY_BYTES = new Bytes(Bytes.toBytes(ENCRYPTION_KEY));</span> |
| <span class="source-line-no">170</span><span id="line-170"></span> |
| <span class="source-line-no">171</span><span id="line-171"> private static final boolean DEFAULT_MOB = false;</span> |
| <span class="source-line-no">172</span><span id="line-172"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">173</span><span id="line-173"> public static final String IS_MOB = "IS_MOB";</span> |
| <span class="source-line-no">174</span><span id="line-174"> private static final Bytes IS_MOB_BYTES = new Bytes(Bytes.toBytes(IS_MOB));</span> |
| <span class="source-line-no">175</span><span id="line-175"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">176</span><span id="line-176"> public static final String MOB_THRESHOLD = "MOB_THRESHOLD";</span> |
| <span class="source-line-no">177</span><span id="line-177"> private static final Bytes MOB_THRESHOLD_BYTES = new Bytes(Bytes.toBytes(MOB_THRESHOLD));</span> |
| <span class="source-line-no">178</span><span id="line-178"> public static final long DEFAULT_MOB_THRESHOLD = 100 * 1024; // 100k</span> |
| <span class="source-line-no">179</span><span id="line-179"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">180</span><span id="line-180"> public static final String MOB_COMPACT_PARTITION_POLICY = "MOB_COMPACT_PARTITION_POLICY";</span> |
| <span class="source-line-no">181</span><span id="line-181"> private static final Bytes MOB_COMPACT_PARTITION_POLICY_BYTES =</span> |
| <span class="source-line-no">182</span><span id="line-182"> new Bytes(Bytes.toBytes(MOB_COMPACT_PARTITION_POLICY));</span> |
| <span class="source-line-no">183</span><span id="line-183"> public static final MobCompactPartitionPolicy DEFAULT_MOB_COMPACT_PARTITION_POLICY =</span> |
| <span class="source-line-no">184</span><span id="line-184"> MobCompactPartitionPolicy.DAILY;</span> |
| <span class="source-line-no">185</span><span id="line-185"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">186</span><span id="line-186"> public static final String DFS_REPLICATION = "DFS_REPLICATION";</span> |
| <span class="source-line-no">187</span><span id="line-187"> private static final Bytes DFS_REPLICATION_BYTES = new Bytes(Bytes.toBytes(DFS_REPLICATION));</span> |
| <span class="source-line-no">188</span><span id="line-188"> public static final short DEFAULT_DFS_REPLICATION = 0;</span> |
| <span class="source-line-no">189</span><span id="line-189"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">190</span><span id="line-190"> public static final String STORAGE_POLICY = "STORAGE_POLICY";</span> |
| <span class="source-line-no">191</span><span id="line-191"> private static final Bytes STORAGE_POLICY_BYTES = new Bytes(Bytes.toBytes(STORAGE_POLICY));</span> |
| <span class="source-line-no">192</span><span id="line-192"></span> |
| <span class="source-line-no">193</span><span id="line-193"> public static final String NEW_VERSION_BEHAVIOR = "NEW_VERSION_BEHAVIOR";</span> |
| <span class="source-line-no">194</span><span id="line-194"> private static final Bytes NEW_VERSION_BEHAVIOR_BYTES =</span> |
| <span class="source-line-no">195</span><span id="line-195"> new Bytes(Bytes.toBytes(NEW_VERSION_BEHAVIOR));</span> |
| <span class="source-line-no">196</span><span id="line-196"> public static final boolean DEFAULT_NEW_VERSION_BEHAVIOR = false;</span> |
| <span class="source-line-no">197</span><span id="line-197"> /**</span> |
| <span class="source-line-no">198</span><span id="line-198"> * Default compression type.</span> |
| <span class="source-line-no">199</span><span id="line-199"> */</span> |
| <span class="source-line-no">200</span><span id="line-200"> public static final Compression.Algorithm DEFAULT_COMPRESSION = Compression.Algorithm.NONE;</span> |
| <span class="source-line-no">201</span><span id="line-201"></span> |
| <span class="source-line-no">202</span><span id="line-202"> /**</span> |
| <span class="source-line-no">203</span><span id="line-203"> * Default data block encoding algorithm.</span> |
| <span class="source-line-no">204</span><span id="line-204"> */</span> |
| <span class="source-line-no">205</span><span id="line-205"> public static final DataBlockEncoding DEFAULT_DATA_BLOCK_ENCODING = DataBlockEncoding.NONE;</span> |
| <span class="source-line-no">206</span><span id="line-206"></span> |
| <span class="source-line-no">207</span><span id="line-207"> /**</span> |
| <span class="source-line-no">208</span><span id="line-208"> * Default index block encoding algorithm.</span> |
| <span class="source-line-no">209</span><span id="line-209"> */</span> |
| <span class="source-line-no">210</span><span id="line-210"> public static final IndexBlockEncoding DEFAULT_INDEX_BLOCK_ENCODING = IndexBlockEncoding.NONE;</span> |
| <span class="source-line-no">211</span><span id="line-211"></span> |
| <span class="source-line-no">212</span><span id="line-212"> /**</span> |
| <span class="source-line-no">213</span><span id="line-213"> * Default number of versions of a record to keep.</span> |
| <span class="source-line-no">214</span><span id="line-214"> */</span> |
| <span class="source-line-no">215</span><span id="line-215"> public static final int DEFAULT_MAX_VERSIONS = 1;</span> |
| <span class="source-line-no">216</span><span id="line-216"></span> |
| <span class="source-line-no">217</span><span id="line-217"> /**</span> |
| <span class="source-line-no">218</span><span id="line-218"> * Default is not to keep a minimum of versions.</span> |
| <span class="source-line-no">219</span><span id="line-219"> */</span> |
| <span class="source-line-no">220</span><span id="line-220"> public static final int DEFAULT_MIN_VERSIONS = 0;</span> |
| <span class="source-line-no">221</span><span id="line-221"></span> |
| <span class="source-line-no">222</span><span id="line-222"> /**</span> |
| <span class="source-line-no">223</span><span id="line-223"> * Default setting for whether to try and serve this column family from memory or not.</span> |
| <span class="source-line-no">224</span><span id="line-224"> */</span> |
| <span class="source-line-no">225</span><span id="line-225"> public static final boolean DEFAULT_IN_MEMORY = false;</span> |
| <span class="source-line-no">226</span><span id="line-226"></span> |
| <span class="source-line-no">227</span><span id="line-227"> /**</span> |
| <span class="source-line-no">228</span><span id="line-228"> * Default setting for preventing deleted from being collected immediately.</span> |
| <span class="source-line-no">229</span><span id="line-229"> */</span> |
| <span class="source-line-no">230</span><span id="line-230"> public static final KeepDeletedCells DEFAULT_KEEP_DELETED = KeepDeletedCells.FALSE;</span> |
| <span class="source-line-no">231</span><span id="line-231"></span> |
| <span class="source-line-no">232</span><span id="line-232"> /**</span> |
| <span class="source-line-no">233</span><span id="line-233"> * Default setting for whether to use a block cache or not.</span> |
| <span class="source-line-no">234</span><span id="line-234"> */</span> |
| <span class="source-line-no">235</span><span id="line-235"> public static final boolean DEFAULT_BLOCKCACHE = true;</span> |
| <span class="source-line-no">236</span><span id="line-236"></span> |
| <span class="source-line-no">237</span><span id="line-237"> /**</span> |
| <span class="source-line-no">238</span><span id="line-238"> * Default setting for whether to cache data blocks on write if block caching is enabled.</span> |
| <span class="source-line-no">239</span><span id="line-239"> */</span> |
| <span class="source-line-no">240</span><span id="line-240"> public static final boolean DEFAULT_CACHE_DATA_ON_WRITE = false;</span> |
| <span class="source-line-no">241</span><span id="line-241"></span> |
| <span class="source-line-no">242</span><span id="line-242"> /**</span> |
| <span class="source-line-no">243</span><span id="line-243"> * Default setting for whether to cache index blocks on write if block caching is enabled.</span> |
| <span class="source-line-no">244</span><span id="line-244"> */</span> |
| <span class="source-line-no">245</span><span id="line-245"> public static final boolean DEFAULT_CACHE_INDEX_ON_WRITE = false;</span> |
| <span class="source-line-no">246</span><span id="line-246"></span> |
| <span class="source-line-no">247</span><span id="line-247"> /**</span> |
| <span class="source-line-no">248</span><span id="line-248"> * Default size of blocks in files stored to the filesytem (hfiles).</span> |
| <span class="source-line-no">249</span><span id="line-249"> */</span> |
| <span class="source-line-no">250</span><span id="line-250"> public static final int DEFAULT_BLOCKSIZE = HConstants.DEFAULT_BLOCKSIZE;</span> |
| <span class="source-line-no">251</span><span id="line-251"></span> |
| <span class="source-line-no">252</span><span id="line-252"> /**</span> |
| <span class="source-line-no">253</span><span id="line-253"> * Default setting for whether or not to use bloomfilters.</span> |
| <span class="source-line-no">254</span><span id="line-254"> */</span> |
| <span class="source-line-no">255</span><span id="line-255"> public static final BloomType DEFAULT_BLOOMFILTER = BloomType.ROW;</span> |
| <span class="source-line-no">256</span><span id="line-256"></span> |
| <span class="source-line-no">257</span><span id="line-257"> /**</span> |
| <span class="source-line-no">258</span><span id="line-258"> * Default setting for whether to cache bloom filter blocks on write if block caching is enabled.</span> |
| <span class="source-line-no">259</span><span id="line-259"> */</span> |
| <span class="source-line-no">260</span><span id="line-260"> public static final boolean DEFAULT_CACHE_BLOOMS_ON_WRITE = false;</span> |
| <span class="source-line-no">261</span><span id="line-261"></span> |
| <span class="source-line-no">262</span><span id="line-262"> /**</span> |
| <span class="source-line-no">263</span><span id="line-263"> * Default time to live of cell contents.</span> |
| <span class="source-line-no">264</span><span id="line-264"> */</span> |
| <span class="source-line-no">265</span><span id="line-265"> public static final int DEFAULT_TTL = HConstants.FOREVER;</span> |
| <span class="source-line-no">266</span><span id="line-266"></span> |
| <span class="source-line-no">267</span><span id="line-267"> /**</span> |
| <span class="source-line-no">268</span><span id="line-268"> * Default scope.</span> |
| <span class="source-line-no">269</span><span id="line-269"> */</span> |
| <span class="source-line-no">270</span><span id="line-270"> public static final int DEFAULT_REPLICATION_SCOPE = HConstants.REPLICATION_SCOPE_LOCAL;</span> |
| <span class="source-line-no">271</span><span id="line-271"></span> |
| <span class="source-line-no">272</span><span id="line-272"> /**</span> |
| <span class="source-line-no">273</span><span id="line-273"> * Default setting for whether to evict cached blocks from the blockcache on close.</span> |
| <span class="source-line-no">274</span><span id="line-274"> */</span> |
| <span class="source-line-no">275</span><span id="line-275"> public static final boolean DEFAULT_EVICT_BLOCKS_ON_CLOSE = false;</span> |
| <span class="source-line-no">276</span><span id="line-276"></span> |
| <span class="source-line-no">277</span><span id="line-277"> /**</span> |
| <span class="source-line-no">278</span><span id="line-278"> * Default compress tags along with any type of DataBlockEncoding.</span> |
| <span class="source-line-no">279</span><span id="line-279"> */</span> |
| <span class="source-line-no">280</span><span id="line-280"> public static final boolean DEFAULT_COMPRESS_TAGS = true;</span> |
| <span class="source-line-no">281</span><span id="line-281"></span> |
| <span class="source-line-no">282</span><span id="line-282"> /*</span> |
| <span class="source-line-no">283</span><span id="line-283"> * Default setting for whether to prefetch blocks into the blockcache on open.</span> |
| <span class="source-line-no">284</span><span id="line-284"> */</span> |
| <span class="source-line-no">285</span><span id="line-285"> public static final boolean DEFAULT_PREFETCH_BLOCKS_ON_OPEN = false;</span> |
| <span class="source-line-no">286</span><span id="line-286"></span> |
| <span class="source-line-no">287</span><span id="line-287"> private final static Map<String, String> DEFAULT_VALUES = new HashMap<>();</span> |
| <span class="source-line-no">288</span><span id="line-288"></span> |
| <span class="source-line-no">289</span><span id="line-289"> private static Map<Bytes, Bytes> getDefaultValuesBytes() {</span> |
| <span class="source-line-no">290</span><span id="line-290"> Map<Bytes, Bytes> values = new HashMap<>();</span> |
| <span class="source-line-no">291</span><span id="line-291"> DEFAULT_VALUES</span> |
| <span class="source-line-no">292</span><span id="line-292"> .forEach((k, v) -> values.put(new Bytes(Bytes.toBytes(k)), new Bytes(Bytes.toBytes(v))));</span> |
| <span class="source-line-no">293</span><span id="line-293"> return values;</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 static Map<String, String> getDefaultValues() {</span> |
| <span class="source-line-no">297</span><span id="line-297"> return Collections.unmodifiableMap(DEFAULT_VALUES);</span> |
| <span class="source-line-no">298</span><span id="line-298"> }</span> |
| <span class="source-line-no">299</span><span id="line-299"></span> |
| <span class="source-line-no">300</span><span id="line-300"> private final static Set<Bytes> RESERVED_KEYWORDS = new HashSet<>();</span> |
| <span class="source-line-no">301</span><span id="line-301"></span> |
| <span class="source-line-no">302</span><span id="line-302"> static {</span> |
| <span class="source-line-no">303</span><span id="line-303"> DEFAULT_VALUES.put(BLOOMFILTER, DEFAULT_BLOOMFILTER.name());</span> |
| <span class="source-line-no">304</span><span id="line-304"> DEFAULT_VALUES.put(REPLICATION_SCOPE, String.valueOf(DEFAULT_REPLICATION_SCOPE));</span> |
| <span class="source-line-no">305</span><span id="line-305"> DEFAULT_VALUES.put(MAX_VERSIONS, String.valueOf(DEFAULT_MAX_VERSIONS));</span> |
| <span class="source-line-no">306</span><span id="line-306"> DEFAULT_VALUES.put(MIN_VERSIONS, String.valueOf(DEFAULT_MIN_VERSIONS));</span> |
| <span class="source-line-no">307</span><span id="line-307"> DEFAULT_VALUES.put(COMPRESSION, DEFAULT_COMPRESSION.name());</span> |
| <span class="source-line-no">308</span><span id="line-308"> DEFAULT_VALUES.put(TTL, String.valueOf(DEFAULT_TTL));</span> |
| <span class="source-line-no">309</span><span id="line-309"> DEFAULT_VALUES.put(BLOCKSIZE, String.valueOf(DEFAULT_BLOCKSIZE));</span> |
| <span class="source-line-no">310</span><span id="line-310"> DEFAULT_VALUES.put(IN_MEMORY, String.valueOf(DEFAULT_IN_MEMORY));</span> |
| <span class="source-line-no">311</span><span id="line-311"> DEFAULT_VALUES.put(BLOCKCACHE, String.valueOf(DEFAULT_BLOCKCACHE));</span> |
| <span class="source-line-no">312</span><span id="line-312"> DEFAULT_VALUES.put(KEEP_DELETED_CELLS, String.valueOf(DEFAULT_KEEP_DELETED));</span> |
| <span class="source-line-no">313</span><span id="line-313"> DEFAULT_VALUES.put(DATA_BLOCK_ENCODING, String.valueOf(DEFAULT_DATA_BLOCK_ENCODING));</span> |
| <span class="source-line-no">314</span><span id="line-314"> DEFAULT_VALUES.put(INDEX_BLOCK_ENCODING, String.valueOf(DEFAULT_INDEX_BLOCK_ENCODING));</span> |
| <span class="source-line-no">315</span><span id="line-315"> // Do NOT add this key/value by default. NEW_VERSION_BEHAVIOR is NOT defined in hbase1 so</span> |
| <span class="source-line-no">316</span><span id="line-316"> // it is not possible to make an hbase1 HCD the same as an hbase2 HCD and so the replication</span> |
| <span class="source-line-no">317</span><span id="line-317"> // compare of schemas will fail. It is OK not adding the below to the initial map because of</span> |
| <span class="source-line-no">318</span><span id="line-318"> // fetch of this value, we will check for null and if null will return the default.</span> |
| <span class="source-line-no">319</span><span id="line-319"> // DEFAULT_VALUES.put(NEW_VERSION_BEHAVIOR, String.valueOf(DEFAULT_NEW_VERSION_BEHAVIOR));</span> |
| <span class="source-line-no">320</span><span id="line-320"> DEFAULT_VALUES.keySet().forEach(s -> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(s))));</span> |
| <span class="source-line-no">321</span><span id="line-321"> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(ENCRYPTION)));</span> |
| <span class="source-line-no">322</span><span id="line-322"> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(ENCRYPTION_KEY)));</span> |
| <span class="source-line-no">323</span><span id="line-323"> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(IS_MOB)));</span> |
| <span class="source-line-no">324</span><span id="line-324"> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(MOB_THRESHOLD)));</span> |
| <span class="source-line-no">325</span><span id="line-325"> RESERVED_KEYWORDS.add(new Bytes(Bytes.toBytes(MOB_COMPACT_PARTITION_POLICY)));</span> |
| <span class="source-line-no">326</span><span id="line-326"> }</span> |
| <span class="source-line-no">327</span><span id="line-327"></span> |
| <span class="source-line-no">328</span><span id="line-328"> public static Unit getUnit(String key) {</span> |
| <span class="source-line-no">329</span><span id="line-329"> /* TTL for now, we can add more as we need */</span> |
| <span class="source-line-no">330</span><span id="line-330"> switch (key) {</span> |
| <span class="source-line-no">331</span><span id="line-331"> case TTL:</span> |
| <span class="source-line-no">332</span><span id="line-332"> return Unit.TIME_INTERVAL;</span> |
| <span class="source-line-no">333</span><span id="line-333"> case BLOCKSIZE:</span> |
| <span class="source-line-no">334</span><span id="line-334"> return Unit.BYTE;</span> |
| <span class="source-line-no">335</span><span id="line-335"> default:</span> |
| <span class="source-line-no">336</span><span id="line-336"> return Unit.NONE;</span> |
| <span class="source-line-no">337</span><span id="line-337"> }</span> |
| <span class="source-line-no">338</span><span id="line-338"> }</span> |
| <span class="source-line-no">339</span><span id="line-339"></span> |
| <span class="source-line-no">340</span><span id="line-340"> /**</span> |
| <span class="source-line-no">341</span><span id="line-341"> * Check if the column family name is legal.</span> |
| <span class="source-line-no">342</span><span id="line-342"> * @param b Family name.</span> |
| <span class="source-line-no">343</span><span id="line-343"> * @return <code>b</code></span> |
| <span class="source-line-no">344</span><span id="line-344"> * @throws IllegalArgumentException If not null and not a legitimate family name: i.e. 'printable'</span> |
| <span class="source-line-no">345</span><span id="line-345"> * and ends in a ':' (Null passes are allowed because</span> |
| <span class="source-line-no">346</span><span id="line-346"> * <code>b</code> can be null when deserializing). Cannot start</span> |
| <span class="source-line-no">347</span><span id="line-347"> * with a '.' either. Also Family can not be an empty value or</span> |
| <span class="source-line-no">348</span><span id="line-348"> * equal "recovered.edits".</span> |
| <span class="source-line-no">349</span><span id="line-349"> */</span> |
| <span class="source-line-no">350</span><span id="line-350"> public static byte[] isLegalColumnFamilyName(final byte[] b) {</span> |
| <span class="source-line-no">351</span><span id="line-351"> if (b == null) {</span> |
| <span class="source-line-no">352</span><span id="line-352"> return null;</span> |
| <span class="source-line-no">353</span><span id="line-353"> }</span> |
| <span class="source-line-no">354</span><span id="line-354"> Preconditions.checkArgument(b.length != 0, "Column Family name can not be empty");</span> |
| <span class="source-line-no">355</span><span id="line-355"> if (b[0] == '.') {</span> |
| <span class="source-line-no">356</span><span id="line-356"> throw new IllegalArgumentException(</span> |
| <span class="source-line-no">357</span><span id="line-357"> "Column Family names cannot start with a " + "period: " + Bytes.toString(b));</span> |
| <span class="source-line-no">358</span><span id="line-358"> }</span> |
| <span class="source-line-no">359</span><span id="line-359"> for (int i = 0; i < b.length; i++) {</span> |
| <span class="source-line-no">360</span><span id="line-360"> if (Character.isISOControl(b[i]) || b[i] == ':' || b[i] == '\\' || b[i] == '/') {</span> |
| <span class="source-line-no">361</span><span id="line-361"> throw new IllegalArgumentException("Illegal character <" + b[i]</span> |
| <span class="source-line-no">362</span><span id="line-362"> + ">. Column Family names cannot contain control characters or colons: "</span> |
| <span class="source-line-no">363</span><span id="line-363"> + Bytes.toString(b));</span> |
| <span class="source-line-no">364</span><span id="line-364"> }</span> |
| <span class="source-line-no">365</span><span id="line-365"> }</span> |
| <span class="source-line-no">366</span><span id="line-366"> byte[] recoveredEdit = Bytes.toBytes(HConstants.RECOVERED_EDITS_DIR);</span> |
| <span class="source-line-no">367</span><span id="line-367"> if (Bytes.equals(recoveredEdit, b)) {</span> |
| <span class="source-line-no">368</span><span id="line-368"> throw new IllegalArgumentException(</span> |
| <span class="source-line-no">369</span><span id="line-369"> "Column Family name cannot be: " + HConstants.RECOVERED_EDITS_DIR);</span> |
| <span class="source-line-no">370</span><span id="line-370"> }</span> |
| <span class="source-line-no">371</span><span id="line-371"> return b;</span> |
| <span class="source-line-no">372</span><span id="line-372"> }</span> |
| <span class="source-line-no">373</span><span id="line-373"></span> |
| <span class="source-line-no">374</span><span id="line-374"> private final ModifyableColumnFamilyDescriptor desc;</span> |
| <span class="source-line-no">375</span><span id="line-375"></span> |
| <span class="source-line-no">376</span><span id="line-376"> public static ColumnFamilyDescriptor parseFrom(final byte[] pbBytes)</span> |
| <span class="source-line-no">377</span><span id="line-377"> throws DeserializationException {</span> |
| <span class="source-line-no">378</span><span id="line-378"> return ModifyableColumnFamilyDescriptor.parseFrom(pbBytes);</span> |
| <span class="source-line-no">379</span><span id="line-379"> }</span> |
| <span class="source-line-no">380</span><span id="line-380"></span> |
| <span class="source-line-no">381</span><span id="line-381"> public static ColumnFamilyDescriptorBuilder newBuilder(final byte[] name) {</span> |
| <span class="source-line-no">382</span><span id="line-382"> return new ColumnFamilyDescriptorBuilder(name);</span> |
| <span class="source-line-no">383</span><span id="line-383"> }</span> |
| <span class="source-line-no">384</span><span id="line-384"></span> |
| <span class="source-line-no">385</span><span id="line-385"> public static ColumnFamilyDescriptorBuilder newBuilder(final ColumnFamilyDescriptor desc) {</span> |
| <span class="source-line-no">386</span><span id="line-386"> return new ColumnFamilyDescriptorBuilder(desc);</span> |
| <span class="source-line-no">387</span><span id="line-387"> }</span> |
| <span class="source-line-no">388</span><span id="line-388"></span> |
| <span class="source-line-no">389</span><span id="line-389"> public static ColumnFamilyDescriptor copy(ColumnFamilyDescriptor desc) {</span> |
| <span class="source-line-no">390</span><span id="line-390"> return new ModifyableColumnFamilyDescriptor(desc);</span> |
| <span class="source-line-no">391</span><span id="line-391"> }</span> |
| <span class="source-line-no">392</span><span id="line-392"></span> |
| <span class="source-line-no">393</span><span id="line-393"> public static ColumnFamilyDescriptor of(String name) {</span> |
| <span class="source-line-no">394</span><span id="line-394"> return of(Bytes.toBytes(name));</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"> public static ColumnFamilyDescriptor of(byte[] name) {</span> |
| <span class="source-line-no">398</span><span id="line-398"> return newBuilder(name).build();</span> |
| <span class="source-line-no">399</span><span id="line-399"> }</span> |
| <span class="source-line-no">400</span><span id="line-400"></span> |
| <span class="source-line-no">401</span><span id="line-401"> private ColumnFamilyDescriptorBuilder(final byte[] name) {</span> |
| <span class="source-line-no">402</span><span id="line-402"> this.desc = new ModifyableColumnFamilyDescriptor(name);</span> |
| <span class="source-line-no">403</span><span id="line-403"> }</span> |
| <span class="source-line-no">404</span><span id="line-404"></span> |
| <span class="source-line-no">405</span><span id="line-405"> private ColumnFamilyDescriptorBuilder(final ColumnFamilyDescriptor desc) {</span> |
| <span class="source-line-no">406</span><span id="line-406"> this.desc = new ModifyableColumnFamilyDescriptor(desc);</span> |
| <span class="source-line-no">407</span><span id="line-407"> }</span> |
| <span class="source-line-no">408</span><span id="line-408"></span> |
| <span class="source-line-no">409</span><span id="line-409"> /**</span> |
| <span class="source-line-no">410</span><span id="line-410"> * Serialize the table descriptor to a byte array.</span> |
| <span class="source-line-no">411</span><span id="line-411"> * @param desc The table descriptor to serialize</span> |
| <span class="source-line-no">412</span><span id="line-412"> * @return This instance serialized with pb with pb magic prefix</span> |
| <span class="source-line-no">413</span><span id="line-413"> */</span> |
| <span class="source-line-no">414</span><span id="line-414"> public static byte[] toByteArray(ColumnFamilyDescriptor desc) {</span> |
| <span class="source-line-no">415</span><span id="line-415"> if (desc instanceof ModifyableColumnFamilyDescriptor) {</span> |
| <span class="source-line-no">416</span><span id="line-416"> return ((ModifyableColumnFamilyDescriptor) desc).toByteArray();</span> |
| <span class="source-line-no">417</span><span id="line-417"> }</span> |
| <span class="source-line-no">418</span><span id="line-418"> return new ModifyableColumnFamilyDescriptor(desc).toByteArray();</span> |
| <span class="source-line-no">419</span><span id="line-419"> }</span> |
| <span class="source-line-no">420</span><span id="line-420"></span> |
| <span class="source-line-no">421</span><span id="line-421"> public ColumnFamilyDescriptor build() {</span> |
| <span class="source-line-no">422</span><span id="line-422"> return new ModifyableColumnFamilyDescriptor(desc);</span> |
| <span class="source-line-no">423</span><span id="line-423"> }</span> |
| <span class="source-line-no">424</span><span id="line-424"></span> |
| <span class="source-line-no">425</span><span id="line-425"> public ColumnFamilyDescriptorBuilder removeConfiguration(String key) {</span> |
| <span class="source-line-no">426</span><span id="line-426"> desc.removeConfiguration(key);</span> |
| <span class="source-line-no">427</span><span id="line-427"> return this;</span> |
| <span class="source-line-no">428</span><span id="line-428"> }</span> |
| <span class="source-line-no">429</span><span id="line-429"></span> |
| <span class="source-line-no">430</span><span id="line-430"> public String getNameAsString() {</span> |
| <span class="source-line-no">431</span><span id="line-431"> return desc.getNameAsString();</span> |
| <span class="source-line-no">432</span><span id="line-432"> }</span> |
| <span class="source-line-no">433</span><span id="line-433"></span> |
| <span class="source-line-no">434</span><span id="line-434"> public ColumnFamilyDescriptorBuilder setBlockCacheEnabled(boolean value) {</span> |
| <span class="source-line-no">435</span><span id="line-435"> desc.setBlockCacheEnabled(value);</span> |
| <span class="source-line-no">436</span><span id="line-436"> return this;</span> |
| <span class="source-line-no">437</span><span id="line-437"> }</span> |
| <span class="source-line-no">438</span><span id="line-438"></span> |
| <span class="source-line-no">439</span><span id="line-439"> public ColumnFamilyDescriptorBuilder setBlocksize(int value) {</span> |
| <span class="source-line-no">440</span><span id="line-440"> desc.setBlocksize(value);</span> |
| <span class="source-line-no">441</span><span id="line-441"> return this;</span> |
| <span class="source-line-no">442</span><span id="line-442"> }</span> |
| <span class="source-line-no">443</span><span id="line-443"></span> |
| <span class="source-line-no">444</span><span id="line-444"> public ColumnFamilyDescriptorBuilder setBlocksize(String value) throws HBaseException {</span> |
| <span class="source-line-no">445</span><span id="line-445"> desc.setBlocksize(value);</span> |
| <span class="source-line-no">446</span><span id="line-446"> return this;</span> |
| <span class="source-line-no">447</span><span id="line-447"> }</span> |
| <span class="source-line-no">448</span><span id="line-448"></span> |
| <span class="source-line-no">449</span><span id="line-449"> public ColumnFamilyDescriptorBuilder setBloomFilterType(final BloomType value) {</span> |
| <span class="source-line-no">450</span><span id="line-450"> desc.setBloomFilterType(value);</span> |
| <span class="source-line-no">451</span><span id="line-451"> return this;</span> |
| <span class="source-line-no">452</span><span id="line-452"> }</span> |
| <span class="source-line-no">453</span><span id="line-453"></span> |
| <span class="source-line-no">454</span><span id="line-454"> public ColumnFamilyDescriptorBuilder setCacheBloomsOnWrite(boolean value) {</span> |
| <span class="source-line-no">455</span><span id="line-455"> desc.setCacheBloomsOnWrite(value);</span> |
| <span class="source-line-no">456</span><span id="line-456"> return this;</span> |
| <span class="source-line-no">457</span><span id="line-457"> }</span> |
| <span class="source-line-no">458</span><span id="line-458"></span> |
| <span class="source-line-no">459</span><span id="line-459"> public ColumnFamilyDescriptorBuilder setCacheDataOnWrite(boolean value) {</span> |
| <span class="source-line-no">460</span><span id="line-460"> desc.setCacheDataOnWrite(value);</span> |
| <span class="source-line-no">461</span><span id="line-461"> return this;</span> |
| <span class="source-line-no">462</span><span id="line-462"> }</span> |
| <span class="source-line-no">463</span><span id="line-463"></span> |
| <span class="source-line-no">464</span><span id="line-464"> public ColumnFamilyDescriptorBuilder setCacheIndexesOnWrite(final boolean value) {</span> |
| <span class="source-line-no">465</span><span id="line-465"> desc.setCacheIndexesOnWrite(value);</span> |
| <span class="source-line-no">466</span><span id="line-466"> return this;</span> |
| <span class="source-line-no">467</span><span id="line-467"> }</span> |
| <span class="source-line-no">468</span><span id="line-468"></span> |
| <span class="source-line-no">469</span><span id="line-469"> public ColumnFamilyDescriptorBuilder setCompactionCompressionType(Compression.Algorithm value) {</span> |
| <span class="source-line-no">470</span><span id="line-470"> desc.setCompactionCompressionType(value);</span> |
| <span class="source-line-no">471</span><span id="line-471"> return this;</span> |
| <span class="source-line-no">472</span><span id="line-472"> }</span> |
| <span class="source-line-no">473</span><span id="line-473"></span> |
| <span class="source-line-no">474</span><span id="line-474"> public ColumnFamilyDescriptorBuilder</span> |
| <span class="source-line-no">475</span><span id="line-475"> setMajorCompactionCompressionType(Compression.Algorithm value) {</span> |
| <span class="source-line-no">476</span><span id="line-476"> desc.setMajorCompactionCompressionType(value);</span> |
| <span class="source-line-no">477</span><span id="line-477"> return this;</span> |
| <span class="source-line-no">478</span><span id="line-478"> }</span> |
| <span class="source-line-no">479</span><span id="line-479"></span> |
| <span class="source-line-no">480</span><span id="line-480"> public ColumnFamilyDescriptorBuilder</span> |
| <span class="source-line-no">481</span><span id="line-481"> setMinorCompactionCompressionType(Compression.Algorithm value) {</span> |
| <span class="source-line-no">482</span><span id="line-482"> desc.setMinorCompactionCompressionType(value);</span> |
| <span class="source-line-no">483</span><span id="line-483"> return this;</span> |
| <span class="source-line-no">484</span><span id="line-484"> }</span> |
| <span class="source-line-no">485</span><span id="line-485"></span> |
| <span class="source-line-no">486</span><span id="line-486"> public ColumnFamilyDescriptorBuilder setCompressTags(boolean value) {</span> |
| <span class="source-line-no">487</span><span id="line-487"> desc.setCompressTags(value);</span> |
| <span class="source-line-no">488</span><span id="line-488"> return this;</span> |
| <span class="source-line-no">489</span><span id="line-489"> }</span> |
| <span class="source-line-no">490</span><span id="line-490"></span> |
| <span class="source-line-no">491</span><span id="line-491"> public ColumnFamilyDescriptorBuilder setCompressionType(Compression.Algorithm value) {</span> |
| <span class="source-line-no">492</span><span id="line-492"> desc.setCompressionType(value);</span> |
| <span class="source-line-no">493</span><span id="line-493"> return this;</span> |
| <span class="source-line-no">494</span><span id="line-494"> }</span> |
| <span class="source-line-no">495</span><span id="line-495"></span> |
| <span class="source-line-no">496</span><span id="line-496"> public Compression.Algorithm getCompressionType() {</span> |
| <span class="source-line-no">497</span><span id="line-497"> return desc.getCompressionType();</span> |
| <span class="source-line-no">498</span><span id="line-498"> }</span> |
| <span class="source-line-no">499</span><span id="line-499"></span> |
| <span class="source-line-no">500</span><span id="line-500"> public ColumnFamilyDescriptorBuilder setConfiguration(final String key, final String value) {</span> |
| <span class="source-line-no">501</span><span id="line-501"> desc.setConfiguration(key, value);</span> |
| <span class="source-line-no">502</span><span id="line-502"> return this;</span> |
| <span class="source-line-no">503</span><span id="line-503"> }</span> |
| <span class="source-line-no">504</span><span id="line-504"></span> |
| <span class="source-line-no">505</span><span id="line-505"> public ColumnFamilyDescriptorBuilder setDFSReplication(short value) {</span> |
| <span class="source-line-no">506</span><span id="line-506"> desc.setDFSReplication(value);</span> |
| <span class="source-line-no">507</span><span id="line-507"> return this;</span> |
| <span class="source-line-no">508</span><span id="line-508"> }</span> |
| <span class="source-line-no">509</span><span id="line-509"></span> |
| <span class="source-line-no">510</span><span id="line-510"> public ColumnFamilyDescriptorBuilder setDataBlockEncoding(DataBlockEncoding value) {</span> |
| <span class="source-line-no">511</span><span id="line-511"> desc.setDataBlockEncoding(value);</span> |
| <span class="source-line-no">512</span><span id="line-512"> return this;</span> |
| <span class="source-line-no">513</span><span id="line-513"> }</span> |
| <span class="source-line-no">514</span><span id="line-514"></span> |
| <span class="source-line-no">515</span><span id="line-515"> public ColumnFamilyDescriptorBuilder setIndexBlockEncoding(IndexBlockEncoding value) {</span> |
| <span class="source-line-no">516</span><span id="line-516"> desc.setIndexBlockEncoding(value);</span> |
| <span class="source-line-no">517</span><span id="line-517"> return this;</span> |
| <span class="source-line-no">518</span><span id="line-518"> }</span> |
| <span class="source-line-no">519</span><span id="line-519"></span> |
| <span class="source-line-no">520</span><span id="line-520"> public ColumnFamilyDescriptorBuilder setEncryptionKey(final byte[] value) {</span> |
| <span class="source-line-no">521</span><span id="line-521"> desc.setEncryptionKey(value);</span> |
| <span class="source-line-no">522</span><span id="line-522"> return this;</span> |
| <span class="source-line-no">523</span><span id="line-523"> }</span> |
| <span class="source-line-no">524</span><span id="line-524"></span> |
| <span class="source-line-no">525</span><span id="line-525"> public ColumnFamilyDescriptorBuilder setEncryptionType(String value) {</span> |
| <span class="source-line-no">526</span><span id="line-526"> desc.setEncryptionType(value);</span> |
| <span class="source-line-no">527</span><span id="line-527"> return this;</span> |
| <span class="source-line-no">528</span><span id="line-528"> }</span> |
| <span class="source-line-no">529</span><span id="line-529"></span> |
| <span class="source-line-no">530</span><span id="line-530"> public ColumnFamilyDescriptorBuilder setEvictBlocksOnClose(boolean value) {</span> |
| <span class="source-line-no">531</span><span id="line-531"> desc.setEvictBlocksOnClose(value);</span> |
| <span class="source-line-no">532</span><span id="line-532"> return this;</span> |
| <span class="source-line-no">533</span><span id="line-533"> }</span> |
| <span class="source-line-no">534</span><span id="line-534"></span> |
| <span class="source-line-no">535</span><span id="line-535"> public ColumnFamilyDescriptorBuilder setInMemory(final boolean value) {</span> |
| <span class="source-line-no">536</span><span id="line-536"> desc.setInMemory(value);</span> |
| <span class="source-line-no">537</span><span id="line-537"> return this;</span> |
| <span class="source-line-no">538</span><span id="line-538"> }</span> |
| <span class="source-line-no">539</span><span id="line-539"></span> |
| <span class="source-line-no">540</span><span id="line-540"> public ColumnFamilyDescriptorBuilder setInMemoryCompaction(final MemoryCompactionPolicy value) {</span> |
| <span class="source-line-no">541</span><span id="line-541"> desc.setInMemoryCompaction(value);</span> |
| <span class="source-line-no">542</span><span id="line-542"> return this;</span> |
| <span class="source-line-no">543</span><span id="line-543"> }</span> |
| <span class="source-line-no">544</span><span id="line-544"></span> |
| <span class="source-line-no">545</span><span id="line-545"> public ColumnFamilyDescriptorBuilder setKeepDeletedCells(KeepDeletedCells value) {</span> |
| <span class="source-line-no">546</span><span id="line-546"> desc.setKeepDeletedCells(value);</span> |
| <span class="source-line-no">547</span><span id="line-547"> return this;</span> |
| <span class="source-line-no">548</span><span id="line-548"> }</span> |
| <span class="source-line-no">549</span><span id="line-549"></span> |
| <span class="source-line-no">550</span><span id="line-550"> public ColumnFamilyDescriptorBuilder setMaxVersions(final int value) {</span> |
| <span class="source-line-no">551</span><span id="line-551"> desc.setMaxVersions(value);</span> |
| <span class="source-line-no">552</span><span id="line-552"> return this;</span> |
| <span class="source-line-no">553</span><span id="line-553"> }</span> |
| <span class="source-line-no">554</span><span id="line-554"></span> |
| <span class="source-line-no">555</span><span id="line-555"> public ColumnFamilyDescriptorBuilder setMinVersions(final int value) {</span> |
| <span class="source-line-no">556</span><span id="line-556"> desc.setMinVersions(value);</span> |
| <span class="source-line-no">557</span><span id="line-557"> return this;</span> |
| <span class="source-line-no">558</span><span id="line-558"> }</span> |
| <span class="source-line-no">559</span><span id="line-559"></span> |
| <span class="source-line-no">560</span><span id="line-560"> public ColumnFamilyDescriptorBuilder</span> |
| <span class="source-line-no">561</span><span id="line-561"> setMobCompactPartitionPolicy(final MobCompactPartitionPolicy value) {</span> |
| <span class="source-line-no">562</span><span id="line-562"> desc.setMobCompactPartitionPolicy(value);</span> |
| <span class="source-line-no">563</span><span id="line-563"> return this;</span> |
| <span class="source-line-no">564</span><span id="line-564"> }</span> |
| <span class="source-line-no">565</span><span id="line-565"></span> |
| <span class="source-line-no">566</span><span id="line-566"> public ColumnFamilyDescriptorBuilder setMobEnabled(final boolean value) {</span> |
| <span class="source-line-no">567</span><span id="line-567"> desc.setMobEnabled(value);</span> |
| <span class="source-line-no">568</span><span id="line-568"> return this;</span> |
| <span class="source-line-no">569</span><span id="line-569"> }</span> |
| <span class="source-line-no">570</span><span id="line-570"></span> |
| <span class="source-line-no">571</span><span id="line-571"> public ColumnFamilyDescriptorBuilder setMobThreshold(final long value) {</span> |
| <span class="source-line-no">572</span><span id="line-572"> desc.setMobThreshold(value);</span> |
| <span class="source-line-no">573</span><span id="line-573"> return this;</span> |
| <span class="source-line-no">574</span><span id="line-574"> }</span> |
| <span class="source-line-no">575</span><span id="line-575"></span> |
| <span class="source-line-no">576</span><span id="line-576"> public ColumnFamilyDescriptorBuilder setPrefetchBlocksOnOpen(final boolean value) {</span> |
| <span class="source-line-no">577</span><span id="line-577"> desc.setPrefetchBlocksOnOpen(value);</span> |
| <span class="source-line-no">578</span><span id="line-578"> return this;</span> |
| <span class="source-line-no">579</span><span id="line-579"> }</span> |
| <span class="source-line-no">580</span><span id="line-580"></span> |
| <span class="source-line-no">581</span><span id="line-581"> public ColumnFamilyDescriptorBuilder setScope(final int value) {</span> |
| <span class="source-line-no">582</span><span id="line-582"> desc.setScope(value);</span> |
| <span class="source-line-no">583</span><span id="line-583"> return this;</span> |
| <span class="source-line-no">584</span><span id="line-584"> }</span> |
| <span class="source-line-no">585</span><span id="line-585"></span> |
| <span class="source-line-no">586</span><span id="line-586"> public ColumnFamilyDescriptorBuilder setStoragePolicy(final String value) {</span> |
| <span class="source-line-no">587</span><span id="line-587"> desc.setStoragePolicy(value);</span> |
| <span class="source-line-no">588</span><span id="line-588"> return this;</span> |
| <span class="source-line-no">589</span><span id="line-589"> }</span> |
| <span class="source-line-no">590</span><span id="line-590"></span> |
| <span class="source-line-no">591</span><span id="line-591"> public ColumnFamilyDescriptorBuilder setTimeToLive(final int value) {</span> |
| <span class="source-line-no">592</span><span id="line-592"> desc.setTimeToLive(value);</span> |
| <span class="source-line-no">593</span><span id="line-593"> return this;</span> |
| <span class="source-line-no">594</span><span id="line-594"> }</span> |
| <span class="source-line-no">595</span><span id="line-595"></span> |
| <span class="source-line-no">596</span><span id="line-596"> public ColumnFamilyDescriptorBuilder setTimeToLive(final String value) throws HBaseException {</span> |
| <span class="source-line-no">597</span><span id="line-597"> desc.setTimeToLive(value);</span> |
| <span class="source-line-no">598</span><span id="line-598"> return this;</span> |
| <span class="source-line-no">599</span><span id="line-599"> }</span> |
| <span class="source-line-no">600</span><span id="line-600"></span> |
| <span class="source-line-no">601</span><span id="line-601"> public ColumnFamilyDescriptorBuilder setNewVersionBehavior(final boolean value) {</span> |
| <span class="source-line-no">602</span><span id="line-602"> desc.setNewVersionBehavior(value);</span> |
| <span class="source-line-no">603</span><span id="line-603"> return this;</span> |
| <span class="source-line-no">604</span><span id="line-604"> }</span> |
| <span class="source-line-no">605</span><span id="line-605"></span> |
| <span class="source-line-no">606</span><span id="line-606"> public ColumnFamilyDescriptorBuilder setValue(final Bytes key, final Bytes value) {</span> |
| <span class="source-line-no">607</span><span id="line-607"> desc.setValue(key, value);</span> |
| <span class="source-line-no">608</span><span id="line-608"> return this;</span> |
| <span class="source-line-no">609</span><span id="line-609"> }</span> |
| <span class="source-line-no">610</span><span id="line-610"></span> |
| <span class="source-line-no">611</span><span id="line-611"> public ColumnFamilyDescriptorBuilder setValue(final byte[] key, final byte[] value) {</span> |
| <span class="source-line-no">612</span><span id="line-612"> desc.setValue(key, value);</span> |
| <span class="source-line-no">613</span><span id="line-613"> return this;</span> |
| <span class="source-line-no">614</span><span id="line-614"> }</span> |
| <span class="source-line-no">615</span><span id="line-615"></span> |
| <span class="source-line-no">616</span><span id="line-616"> public ColumnFamilyDescriptorBuilder setValue(final String key, final String value) {</span> |
| <span class="source-line-no">617</span><span id="line-617"> desc.setValue(key, value);</span> |
| <span class="source-line-no">618</span><span id="line-618"> return this;</span> |
| <span class="source-line-no">619</span><span id="line-619"> }</span> |
| <span class="source-line-no">620</span><span id="line-620"></span> |
| <span class="source-line-no">621</span><span id="line-621"> public ColumnFamilyDescriptorBuilder setVersionsWithTimeToLive(final int retentionInterval,</span> |
| <span class="source-line-no">622</span><span id="line-622"> final int versionAfterInterval) {</span> |
| <span class="source-line-no">623</span><span id="line-623"> desc.setVersionsWithTimeToLive(retentionInterval, versionAfterInterval);</span> |
| <span class="source-line-no">624</span><span id="line-624"> return this;</span> |
| <span class="source-line-no">625</span><span id="line-625"> }</span> |
| <span class="source-line-no">626</span><span id="line-626"></span> |
| <span class="source-line-no">627</span><span id="line-627"> /**</span> |
| <span class="source-line-no">628</span><span id="line-628"> * An ModifyableFamilyDescriptor contains information about a column family such as the number of</span> |
| <span class="source-line-no">629</span><span id="line-629"> * versions, compression settings, etc. It is used as input when creating a table or adding a</span> |
| <span class="source-line-no">630</span><span id="line-630"> * column.</span> |
| <span class="source-line-no">631</span><span id="line-631"> */</span> |
| <span class="source-line-no">632</span><span id="line-632"> private static final class ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">633</span><span id="line-633"> implements ColumnFamilyDescriptor, Comparable<ModifyableColumnFamilyDescriptor> {</span> |
| <span class="source-line-no">634</span><span id="line-634"></span> |
| <span class="source-line-no">635</span><span id="line-635"> // Column family name</span> |
| <span class="source-line-no">636</span><span id="line-636"> private final byte[] name;</span> |
| <span class="source-line-no">637</span><span id="line-637"></span> |
| <span class="source-line-no">638</span><span id="line-638"> // Column metadata</span> |
| <span class="source-line-no">639</span><span id="line-639"> private final Map<Bytes, Bytes> values = new HashMap<>();</span> |
| <span class="source-line-no">640</span><span id="line-640"></span> |
| <span class="source-line-no">641</span><span id="line-641"> /**</span> |
| <span class="source-line-no">642</span><span id="line-642"> * A map which holds the configuration specific to the column family. The keys of the map have</span> |
| <span class="source-line-no">643</span><span id="line-643"> * the same names as config keys and override the defaults with cf-specific settings. Example</span> |
| <span class="source-line-no">644</span><span id="line-644"> * usage may be for compactions, etc.</span> |
| <span class="source-line-no">645</span><span id="line-645"> */</span> |
| <span class="source-line-no">646</span><span id="line-646"> private final Map<String, String> configuration = new HashMap<>();</span> |
| <span class="source-line-no">647</span><span id="line-647"></span> |
| <span class="source-line-no">648</span><span id="line-648"> /**</span> |
| <span class="source-line-no">649</span><span id="line-649"> * Construct a column descriptor specifying only the family name The other attributes are</span> |
| <span class="source-line-no">650</span><span id="line-650"> * defaulted.</span> |
| <span class="source-line-no">651</span><span id="line-651"> * @param name Column family name. Must be 'printable' -- digit or letter -- and may not contain</span> |
| <span class="source-line-no">652</span><span id="line-652"> * a <code>:</code> TODO: make this private after the HCD is removed.</span> |
| <span class="source-line-no">653</span><span id="line-653"> */</span> |
| <span class="source-line-no">654</span><span id="line-654"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">655</span><span id="line-655"> public ModifyableColumnFamilyDescriptor(final byte[] name) {</span> |
| <span class="source-line-no">656</span><span id="line-656"> this(isLegalColumnFamilyName(name), getDefaultValuesBytes(), Collections.emptyMap());</span> |
| <span class="source-line-no">657</span><span id="line-657"> }</span> |
| <span class="source-line-no">658</span><span id="line-658"></span> |
| <span class="source-line-no">659</span><span id="line-659"> /**</span> |
| <span class="source-line-no">660</span><span id="line-660"> * Constructor. Makes a deep copy of the supplied descriptor. TODO: make this private after the</span> |
| <span class="source-line-no">661</span><span id="line-661"> * HCD is removed.</span> |
| <span class="source-line-no">662</span><span id="line-662"> * @param desc The descriptor.</span> |
| <span class="source-line-no">663</span><span id="line-663"> */</span> |
| <span class="source-line-no">664</span><span id="line-664"> @InterfaceAudience.Private</span> |
| <span class="source-line-no">665</span><span id="line-665"> public ModifyableColumnFamilyDescriptor(ColumnFamilyDescriptor desc) {</span> |
| <span class="source-line-no">666</span><span id="line-666"> this(desc.getName(), desc.getValues(), desc.getConfiguration());</span> |
| <span class="source-line-no">667</span><span id="line-667"> }</span> |
| <span class="source-line-no">668</span><span id="line-668"></span> |
| <span class="source-line-no">669</span><span id="line-669"> private ModifyableColumnFamilyDescriptor(byte[] name, Map<Bytes, Bytes> values,</span> |
| <span class="source-line-no">670</span><span id="line-670"> Map<String, String> config) {</span> |
| <span class="source-line-no">671</span><span id="line-671"> this.name = name;</span> |
| <span class="source-line-no">672</span><span id="line-672"> this.values.putAll(values);</span> |
| <span class="source-line-no">673</span><span id="line-673"> this.configuration.putAll(config);</span> |
| <span class="source-line-no">674</span><span id="line-674"> }</span> |
| <span class="source-line-no">675</span><span id="line-675"></span> |
| <span class="source-line-no">676</span><span id="line-676"> @Override</span> |
| <span class="source-line-no">677</span><span id="line-677"> public byte[] getName() {</span> |
| <span class="source-line-no">678</span><span id="line-678"> return Bytes.copy(name);</span> |
| <span class="source-line-no">679</span><span id="line-679"> }</span> |
| <span class="source-line-no">680</span><span id="line-680"></span> |
| <span class="source-line-no">681</span><span id="line-681"> @Override</span> |
| <span class="source-line-no">682</span><span id="line-682"> public String getNameAsString() {</span> |
| <span class="source-line-no">683</span><span id="line-683"> return Bytes.toString(name);</span> |
| <span class="source-line-no">684</span><span id="line-684"> }</span> |
| <span class="source-line-no">685</span><span id="line-685"></span> |
| <span class="source-line-no">686</span><span id="line-686"> @Override</span> |
| <span class="source-line-no">687</span><span id="line-687"> public Bytes getValue(Bytes key) {</span> |
| <span class="source-line-no">688</span><span id="line-688"> return values.get(key);</span> |
| <span class="source-line-no">689</span><span id="line-689"> }</span> |
| <span class="source-line-no">690</span><span id="line-690"></span> |
| <span class="source-line-no">691</span><span id="line-691"> @Override</span> |
| <span class="source-line-no">692</span><span id="line-692"> public byte[] getValue(byte[] key) {</span> |
| <span class="source-line-no">693</span><span id="line-693"> Bytes value = values.get(new Bytes(key));</span> |
| <span class="source-line-no">694</span><span id="line-694"> return value == null ? null : value.get();</span> |
| <span class="source-line-no">695</span><span id="line-695"> }</span> |
| <span class="source-line-no">696</span><span id="line-696"></span> |
| <span class="source-line-no">697</span><span id="line-697"> @Override</span> |
| <span class="source-line-no">698</span><span id="line-698"> public String getValue(String key) {</span> |
| <span class="source-line-no">699</span><span id="line-699"> Bytes rval = values.get(new Bytes(Bytes.toBytes(key)));</span> |
| <span class="source-line-no">700</span><span id="line-700"> return rval == null ? null : Bytes.toString(rval.get(), rval.getOffset(), rval.getLength());</span> |
| <span class="source-line-no">701</span><span id="line-701"> }</span> |
| <span class="source-line-no">702</span><span id="line-702"></span> |
| <span class="source-line-no">703</span><span id="line-703"> @Override</span> |
| <span class="source-line-no">704</span><span id="line-704"> public Map<Bytes, Bytes> getValues() {</span> |
| <span class="source-line-no">705</span><span id="line-705"> return Collections.unmodifiableMap(values);</span> |
| <span class="source-line-no">706</span><span id="line-706"> }</span> |
| <span class="source-line-no">707</span><span id="line-707"></span> |
| <span class="source-line-no">708</span><span id="line-708"> public ModifyableColumnFamilyDescriptor setValue(byte[] key, byte[] value) {</span> |
| <span class="source-line-no">709</span><span id="line-709"> return setValue(toBytesOrNull(key, Function.identity()),</span> |
| <span class="source-line-no">710</span><span id="line-710"> toBytesOrNull(value, Function.identity()));</span> |
| <span class="source-line-no">711</span><span id="line-711"> }</span> |
| <span class="source-line-no">712</span><span id="line-712"></span> |
| <span class="source-line-no">713</span><span id="line-713"> public ModifyableColumnFamilyDescriptor setValue(String key, String value) {</span> |
| <span class="source-line-no">714</span><span id="line-714"> return setValue(toBytesOrNull(key, Bytes::toBytes), toBytesOrNull(value, Bytes::toBytes));</span> |
| <span class="source-line-no">715</span><span id="line-715"> }</span> |
| <span class="source-line-no">716</span><span id="line-716"></span> |
| <span class="source-line-no">717</span><span id="line-717"> private ModifyableColumnFamilyDescriptor setValue(Bytes key, String value) {</span> |
| <span class="source-line-no">718</span><span id="line-718"> return setValue(key, toBytesOrNull(value, Bytes::toBytes));</span> |
| <span class="source-line-no">719</span><span id="line-719"> }</span> |
| <span class="source-line-no">720</span><span id="line-720"></span> |
| <span class="source-line-no">721</span><span id="line-721"> private ModifyableColumnFamilyDescriptor setValue(Bytes key, Bytes value) {</span> |
| <span class="source-line-no">722</span><span id="line-722"> if (value == null || value.getLength() == 0) {</span> |
| <span class="source-line-no">723</span><span id="line-723"> values.remove(key);</span> |
| <span class="source-line-no">724</span><span id="line-724"> } else {</span> |
| <span class="source-line-no">725</span><span id="line-725"> values.put(key, value);</span> |
| <span class="source-line-no">726</span><span id="line-726"> }</span> |
| <span class="source-line-no">727</span><span id="line-727"> return this;</span> |
| <span class="source-line-no">728</span><span id="line-728"> }</span> |
| <span class="source-line-no">729</span><span id="line-729"></span> |
| <span class="source-line-no">730</span><span id="line-730"> private static <T> Bytes toBytesOrNull(T t, Function<T, byte[]> f) {</span> |
| <span class="source-line-no">731</span><span id="line-731"> if (t == null) {</span> |
| <span class="source-line-no">732</span><span id="line-732"> return null;</span> |
| <span class="source-line-no">733</span><span id="line-733"> } else {</span> |
| <span class="source-line-no">734</span><span id="line-734"> return new Bytes(f.apply(t));</span> |
| <span class="source-line-no">735</span><span id="line-735"> }</span> |
| <span class="source-line-no">736</span><span id="line-736"> }</span> |
| <span class="source-line-no">737</span><span id="line-737"></span> |
| <span class="source-line-no">738</span><span id="line-738"> private <T> T getStringOrDefault(Bytes key, Function<String, T> function, T defaultValue) {</span> |
| <span class="source-line-no">739</span><span id="line-739"> return getOrDefault(key, b -> function.apply(Bytes.toString(b)), defaultValue);</span> |
| <span class="source-line-no">740</span><span id="line-740"> }</span> |
| <span class="source-line-no">741</span><span id="line-741"></span> |
| <span class="source-line-no">742</span><span id="line-742"> private <T> T getOrDefault(Bytes key, Function<byte[], T> function, T defaultValue) {</span> |
| <span class="source-line-no">743</span><span id="line-743"> Bytes value = values.get(key);</span> |
| <span class="source-line-no">744</span><span id="line-744"> if (value == null) {</span> |
| <span class="source-line-no">745</span><span id="line-745"> return defaultValue;</span> |
| <span class="source-line-no">746</span><span id="line-746"> } else {</span> |
| <span class="source-line-no">747</span><span id="line-747"> return function.apply(value.get());</span> |
| <span class="source-line-no">748</span><span id="line-748"> }</span> |
| <span class="source-line-no">749</span><span id="line-749"> }</span> |
| <span class="source-line-no">750</span><span id="line-750"></span> |
| <span class="source-line-no">751</span><span id="line-751"> @Override</span> |
| <span class="source-line-no">752</span><span id="line-752"> public int getMaxVersions() {</span> |
| <span class="source-line-no">753</span><span id="line-753"> return getStringOrDefault(MAX_VERSIONS_BYTES, Integer::parseInt, DEFAULT_MAX_VERSIONS);</span> |
| <span class="source-line-no">754</span><span id="line-754"> }</span> |
| <span class="source-line-no">755</span><span id="line-755"></span> |
| <span class="source-line-no">756</span><span id="line-756"> /**</span> |
| <span class="source-line-no">757</span><span id="line-757"> * Set the maximum number of versions to retain.</span> |
| <span class="source-line-no">758</span><span id="line-758"> * @param maxVersions maximum number of versions</span> |
| <span class="source-line-no">759</span><span id="line-759"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">760</span><span id="line-760"> */</span> |
| <span class="source-line-no">761</span><span id="line-761"> public ModifyableColumnFamilyDescriptor setMaxVersions(int maxVersions) {</span> |
| <span class="source-line-no">762</span><span id="line-762"> if (maxVersions <= 0) {</span> |
| <span class="source-line-no">763</span><span id="line-763"> // TODO: Allow maxVersion of 0 to be the way you say "Keep all versions".</span> |
| <span class="source-line-no">764</span><span id="line-764"> // Until there is support, consider 0 or < 0 -- a configuration error.</span> |
| <span class="source-line-no">765</span><span id="line-765"> throw new IllegalArgumentException("Maximum versions must be positive");</span> |
| <span class="source-line-no">766</span><span id="line-766"> }</span> |
| <span class="source-line-no">767</span><span id="line-767"> if (maxVersions < this.getMinVersions()) {</span> |
| <span class="source-line-no">768</span><span id="line-768"> throw new IllegalArgumentException(</span> |
| <span class="source-line-no">769</span><span id="line-769"> "Set MaxVersion to " + maxVersions + " while minVersion is " + this.getMinVersions()</span> |
| <span class="source-line-no">770</span><span id="line-770"> + ". Maximum versions must be >= minimum versions ");</span> |
| <span class="source-line-no">771</span><span id="line-771"> }</span> |
| <span class="source-line-no">772</span><span id="line-772"> setValue(MAX_VERSIONS_BYTES, Integer.toString(maxVersions));</span> |
| <span class="source-line-no">773</span><span id="line-773"> return this;</span> |
| <span class="source-line-no">774</span><span id="line-774"> }</span> |
| <span class="source-line-no">775</span><span id="line-775"></span> |
| <span class="source-line-no">776</span><span id="line-776"> /**</span> |
| <span class="source-line-no">777</span><span id="line-777"> * Set minimum and maximum versions to keep.</span> |
| <span class="source-line-no">778</span><span id="line-778"> * @param minVersions minimal number of versions</span> |
| <span class="source-line-no">779</span><span id="line-779"> * @param maxVersions maximum number of versions</span> |
| <span class="source-line-no">780</span><span id="line-780"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">781</span><span id="line-781"> */</span> |
| <span class="source-line-no">782</span><span id="line-782"> public ModifyableColumnFamilyDescriptor setVersions(int minVersions, int maxVersions) {</span> |
| <span class="source-line-no">783</span><span id="line-783"> if (minVersions <= 0) {</span> |
| <span class="source-line-no">784</span><span id="line-784"> // TODO: Allow minVersion and maxVersion of 0 to be the way you say "Keep all versions".</span> |
| <span class="source-line-no">785</span><span id="line-785"> // Until there is support, consider 0 or < 0 -- a configuration error.</span> |
| <span class="source-line-no">786</span><span id="line-786"> throw new IllegalArgumentException("Minimum versions must be positive");</span> |
| <span class="source-line-no">787</span><span id="line-787"> }</span> |
| <span class="source-line-no">788</span><span id="line-788"></span> |
| <span class="source-line-no">789</span><span id="line-789"> if (maxVersions < minVersions) {</span> |
| <span class="source-line-no">790</span><span id="line-790"> throw new IllegalArgumentException(</span> |
| <span class="source-line-no">791</span><span id="line-791"> "Unable to set MaxVersion to " + maxVersions + " and set MinVersion to " + minVersions</span> |
| <span class="source-line-no">792</span><span id="line-792"> + ", as maximum versions must be >= minimum versions.");</span> |
| <span class="source-line-no">793</span><span id="line-793"> }</span> |
| <span class="source-line-no">794</span><span id="line-794"> setMinVersions(minVersions);</span> |
| <span class="source-line-no">795</span><span id="line-795"> setMaxVersions(maxVersions);</span> |
| <span class="source-line-no">796</span><span id="line-796"> return this;</span> |
| <span class="source-line-no">797</span><span id="line-797"> }</span> |
| <span class="source-line-no">798</span><span id="line-798"></span> |
| <span class="source-line-no">799</span><span id="line-799"> @Override</span> |
| <span class="source-line-no">800</span><span id="line-800"> public int getBlocksize() {</span> |
| <span class="source-line-no">801</span><span id="line-801"> return getStringOrDefault(BLOCKSIZE_BYTES, Integer::valueOf, DEFAULT_BLOCKSIZE);</span> |
| <span class="source-line-no">802</span><span id="line-802"> }</span> |
| <span class="source-line-no">803</span><span id="line-803"></span> |
| <span class="source-line-no">804</span><span id="line-804"> public ModifyableColumnFamilyDescriptor setBlocksize(int s) {</span> |
| <span class="source-line-no">805</span><span id="line-805"> return setValue(BLOCKSIZE_BYTES, Integer.toString(s));</span> |
| <span class="source-line-no">806</span><span id="line-806"> }</span> |
| <span class="source-line-no">807</span><span id="line-807"></span> |
| <span class="source-line-no">808</span><span id="line-808"> public ModifyableColumnFamilyDescriptor setBlocksize(String blocksize) throws HBaseException {</span> |
| <span class="source-line-no">809</span><span id="line-809"> return setBlocksize(</span> |
| <span class="source-line-no">810</span><span id="line-810"> Integer.parseInt(PrettyPrinter.valueOf(blocksize, PrettyPrinter.Unit.BYTE)));</span> |
| <span class="source-line-no">811</span><span id="line-811"> }</span> |
| <span class="source-line-no">812</span><span id="line-812"></span> |
| <span class="source-line-no">813</span><span id="line-813"> @Override</span> |
| <span class="source-line-no">814</span><span id="line-814"> public Compression.Algorithm getCompressionType() {</span> |
| <span class="source-line-no">815</span><span id="line-815"> return getStringOrDefault(COMPRESSION_BYTES,</span> |
| <span class="source-line-no">816</span><span id="line-816"> n -> Compression.Algorithm.valueOf(n.toUpperCase()), DEFAULT_COMPRESSION);</span> |
| <span class="source-line-no">817</span><span id="line-817"> }</span> |
| <span class="source-line-no">818</span><span id="line-818"></span> |
| <span class="source-line-no">819</span><span id="line-819"> /**</span> |
| <span class="source-line-no">820</span><span id="line-820"> * Compression types supported in hbase. LZO is not bundled as part of the hbase distribution.</span> |
| <span class="source-line-no">821</span><span id="line-821"> * See See <a href="http://hbase.apache.org/book.html#lzo.compression">LZO Compression</a> for</span> |
| <span class="source-line-no">822</span><span id="line-822"> * how to enable it.</span> |
| <span class="source-line-no">823</span><span id="line-823"> * @param type Compression type setting.</span> |
| <span class="source-line-no">824</span><span id="line-824"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">825</span><span id="line-825"> */</span> |
| <span class="source-line-no">826</span><span id="line-826"> public ModifyableColumnFamilyDescriptor setCompressionType(Compression.Algorithm type) {</span> |
| <span class="source-line-no">827</span><span id="line-827"> return setValue(COMPRESSION_BYTES, type.name());</span> |
| <span class="source-line-no">828</span><span id="line-828"> }</span> |
| <span class="source-line-no">829</span><span id="line-829"></span> |
| <span class="source-line-no">830</span><span id="line-830"> @Override</span> |
| <span class="source-line-no">831</span><span id="line-831"> public DataBlockEncoding getDataBlockEncoding() {</span> |
| <span class="source-line-no">832</span><span id="line-832"> return getStringOrDefault(DATA_BLOCK_ENCODING_BYTES,</span> |
| <span class="source-line-no">833</span><span id="line-833"> n -> DataBlockEncoding.valueOf(n.toUpperCase()), DataBlockEncoding.NONE);</span> |
| <span class="source-line-no">834</span><span id="line-834"> }</span> |
| <span class="source-line-no">835</span><span id="line-835"></span> |
| <span class="source-line-no">836</span><span id="line-836"> /**</span> |
| <span class="source-line-no">837</span><span id="line-837"> * Set data block encoding algorithm used in block cache.</span> |
| <span class="source-line-no">838</span><span id="line-838"> * @param type What kind of data block encoding will be used.</span> |
| <span class="source-line-no">839</span><span id="line-839"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">840</span><span id="line-840"> */</span> |
| <span class="source-line-no">841</span><span id="line-841"> public ModifyableColumnFamilyDescriptor setDataBlockEncoding(DataBlockEncoding type) {</span> |
| <span class="source-line-no">842</span><span id="line-842"> return setValue(DATA_BLOCK_ENCODING_BYTES,</span> |
| <span class="source-line-no">843</span><span id="line-843"> type == null ? DataBlockEncoding.NONE.name() : type.name());</span> |
| <span class="source-line-no">844</span><span id="line-844"> }</span> |
| <span class="source-line-no">845</span><span id="line-845"></span> |
| <span class="source-line-no">846</span><span id="line-846"> @Override</span> |
| <span class="source-line-no">847</span><span id="line-847"> public IndexBlockEncoding getIndexBlockEncoding() {</span> |
| <span class="source-line-no">848</span><span id="line-848"> return getStringOrDefault(INDEX_BLOCK_ENCODING_BYTES,</span> |
| <span class="source-line-no">849</span><span id="line-849"> n -> IndexBlockEncoding.valueOf(n.toUpperCase()), IndexBlockEncoding.NONE);</span> |
| <span class="source-line-no">850</span><span id="line-850"> }</span> |
| <span class="source-line-no">851</span><span id="line-851"></span> |
| <span class="source-line-no">852</span><span id="line-852"> /**</span> |
| <span class="source-line-no">853</span><span id="line-853"> * Set index block encoding algorithm used in block cache.</span> |
| <span class="source-line-no">854</span><span id="line-854"> * @param type What kind of index block encoding will be used.</span> |
| <span class="source-line-no">855</span><span id="line-855"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">856</span><span id="line-856"> */</span> |
| <span class="source-line-no">857</span><span id="line-857"> public ModifyableColumnFamilyDescriptor setIndexBlockEncoding(IndexBlockEncoding type) {</span> |
| <span class="source-line-no">858</span><span id="line-858"> return setValue(INDEX_BLOCK_ENCODING_BYTES,</span> |
| <span class="source-line-no">859</span><span id="line-859"> type == null ? IndexBlockEncoding.NONE.name() : type.name());</span> |
| <span class="source-line-no">860</span><span id="line-860"> }</span> |
| <span class="source-line-no">861</span><span id="line-861"></span> |
| <span class="source-line-no">862</span><span id="line-862"> /**</span> |
| <span class="source-line-no">863</span><span id="line-863"> * Set whether the tags should be compressed along with DataBlockEncoding. When no</span> |
| <span class="source-line-no">864</span><span id="line-864"> * DataBlockEncoding is been used, this is having no effect.</span> |
| <span class="source-line-no">865</span><span id="line-865"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">866</span><span id="line-866"> */</span> |
| <span class="source-line-no">867</span><span id="line-867"> public ModifyableColumnFamilyDescriptor setCompressTags(boolean compressTags) {</span> |
| <span class="source-line-no">868</span><span id="line-868"> return setValue(COMPRESS_TAGS_BYTES, String.valueOf(compressTags));</span> |
| <span class="source-line-no">869</span><span id="line-869"> }</span> |
| <span class="source-line-no">870</span><span id="line-870"></span> |
| <span class="source-line-no">871</span><span id="line-871"> @Override</span> |
| <span class="source-line-no">872</span><span id="line-872"> public boolean isCompressTags() {</span> |
| <span class="source-line-no">873</span><span id="line-873"> return getStringOrDefault(COMPRESS_TAGS_BYTES, Boolean::valueOf, DEFAULT_COMPRESS_TAGS);</span> |
| <span class="source-line-no">874</span><span id="line-874"> }</span> |
| <span class="source-line-no">875</span><span id="line-875"></span> |
| <span class="source-line-no">876</span><span id="line-876"> @Override</span> |
| <span class="source-line-no">877</span><span id="line-877"> public Compression.Algorithm getCompactionCompressionType() {</span> |
| <span class="source-line-no">878</span><span id="line-878"> return getStringOrDefault(COMPRESSION_COMPACT_BYTES,</span> |
| <span class="source-line-no">879</span><span id="line-879"> n -> Compression.Algorithm.valueOf(n.toUpperCase()), getCompressionType());</span> |
| <span class="source-line-no">880</span><span id="line-880"> }</span> |
| <span class="source-line-no">881</span><span id="line-881"></span> |
| <span class="source-line-no">882</span><span id="line-882"> @Override</span> |
| <span class="source-line-no">883</span><span id="line-883"> public Compression.Algorithm getMajorCompactionCompressionType() {</span> |
| <span class="source-line-no">884</span><span id="line-884"> return getStringOrDefault(COMPRESSION_COMPACT_MAJOR_BYTES,</span> |
| <span class="source-line-no">885</span><span id="line-885"> n -> Compression.Algorithm.valueOf(n.toUpperCase()), getCompactionCompressionType());</span> |
| <span class="source-line-no">886</span><span id="line-886"> }</span> |
| <span class="source-line-no">887</span><span id="line-887"></span> |
| <span class="source-line-no">888</span><span id="line-888"> @Override</span> |
| <span class="source-line-no">889</span><span id="line-889"> public Compression.Algorithm getMinorCompactionCompressionType() {</span> |
| <span class="source-line-no">890</span><span id="line-890"> return getStringOrDefault(COMPRESSION_COMPACT_MINOR_BYTES,</span> |
| <span class="source-line-no">891</span><span id="line-891"> n -> Compression.Algorithm.valueOf(n.toUpperCase()), getCompactionCompressionType());</span> |
| <span class="source-line-no">892</span><span id="line-892"> }</span> |
| <span class="source-line-no">893</span><span id="line-893"></span> |
| <span class="source-line-no">894</span><span id="line-894"> /**</span> |
| <span class="source-line-no">895</span><span id="line-895"> * Compression types supported in hbase. LZO is not bundled as part of the hbase distribution.</span> |
| <span class="source-line-no">896</span><span id="line-896"> * See See <a href="http://hbase.apache.org/book.html#lzo.compression">LZO Compression</a> for</span> |
| <span class="source-line-no">897</span><span id="line-897"> * how to enable it.</span> |
| <span class="source-line-no">898</span><span id="line-898"> * @param type Compression type setting.</span> |
| <span class="source-line-no">899</span><span id="line-899"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">900</span><span id="line-900"> */</span> |
| <span class="source-line-no">901</span><span id="line-901"> public ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">902</span><span id="line-902"> setCompactionCompressionType(Compression.Algorithm type) {</span> |
| <span class="source-line-no">903</span><span id="line-903"> return setValue(COMPRESSION_COMPACT_BYTES, type.name());</span> |
| <span class="source-line-no">904</span><span id="line-904"> }</span> |
| <span class="source-line-no">905</span><span id="line-905"></span> |
| <span class="source-line-no">906</span><span id="line-906"> public ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">907</span><span id="line-907"> setMajorCompactionCompressionType(Compression.Algorithm type) {</span> |
| <span class="source-line-no">908</span><span id="line-908"> return setValue(COMPRESSION_COMPACT_MAJOR_BYTES, type.name());</span> |
| <span class="source-line-no">909</span><span id="line-909"> }</span> |
| <span class="source-line-no">910</span><span id="line-910"></span> |
| <span class="source-line-no">911</span><span id="line-911"> public ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">912</span><span id="line-912"> setMinorCompactionCompressionType(Compression.Algorithm type) {</span> |
| <span class="source-line-no">913</span><span id="line-913"> return setValue(COMPRESSION_COMPACT_MINOR_BYTES, type.name());</span> |
| <span class="source-line-no">914</span><span id="line-914"> }</span> |
| <span class="source-line-no">915</span><span id="line-915"></span> |
| <span class="source-line-no">916</span><span id="line-916"> @Override</span> |
| <span class="source-line-no">917</span><span id="line-917"> public boolean isInMemory() {</span> |
| <span class="source-line-no">918</span><span id="line-918"> return getStringOrDefault(IN_MEMORY_BYTES, Boolean::valueOf, DEFAULT_IN_MEMORY);</span> |
| <span class="source-line-no">919</span><span id="line-919"> }</span> |
| <span class="source-line-no">920</span><span id="line-920"></span> |
| <span class="source-line-no">921</span><span id="line-921"> /**</span> |
| <span class="source-line-no">922</span><span id="line-922"> * Set the inMemory flag</span> |
| <span class="source-line-no">923</span><span id="line-923"> * @param inMemory True if we are to favor keeping all values for this column family in the</span> |
| <span class="source-line-no">924</span><span id="line-924"> * HRegionServer cache</span> |
| <span class="source-line-no">925</span><span id="line-925"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">926</span><span id="line-926"> */</span> |
| <span class="source-line-no">927</span><span id="line-927"> public ModifyableColumnFamilyDescriptor setInMemory(boolean inMemory) {</span> |
| <span class="source-line-no">928</span><span id="line-928"> return setValue(IN_MEMORY_BYTES, Boolean.toString(inMemory));</span> |
| <span class="source-line-no">929</span><span id="line-929"> }</span> |
| <span class="source-line-no">930</span><span id="line-930"></span> |
| <span class="source-line-no">931</span><span id="line-931"> @Override</span> |
| <span class="source-line-no">932</span><span id="line-932"> public MemoryCompactionPolicy getInMemoryCompaction() {</span> |
| <span class="source-line-no">933</span><span id="line-933"> return getStringOrDefault(IN_MEMORY_COMPACTION_BYTES,</span> |
| <span class="source-line-no">934</span><span id="line-934"> n -> MemoryCompactionPolicy.valueOf(n.toUpperCase()), null);</span> |
| <span class="source-line-no">935</span><span id="line-935"> }</span> |
| <span class="source-line-no">936</span><span id="line-936"></span> |
| <span class="source-line-no">937</span><span id="line-937"> public ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">938</span><span id="line-938"> setInMemoryCompaction(MemoryCompactionPolicy inMemoryCompaction) {</span> |
| <span class="source-line-no">939</span><span id="line-939"> return setValue(IN_MEMORY_COMPACTION_BYTES, inMemoryCompaction.name());</span> |
| <span class="source-line-no">940</span><span id="line-940"> }</span> |
| <span class="source-line-no">941</span><span id="line-941"></span> |
| <span class="source-line-no">942</span><span id="line-942"> @Override</span> |
| <span class="source-line-no">943</span><span id="line-943"> public KeepDeletedCells getKeepDeletedCells() {</span> |
| <span class="source-line-no">944</span><span id="line-944"> return getStringOrDefault(KEEP_DELETED_CELLS_BYTES, KeepDeletedCells::getValue,</span> |
| <span class="source-line-no">945</span><span id="line-945"> DEFAULT_KEEP_DELETED);</span> |
| <span class="source-line-no">946</span><span id="line-946"> }</span> |
| <span class="source-line-no">947</span><span id="line-947"></span> |
| <span class="source-line-no">948</span><span id="line-948"> public ModifyableColumnFamilyDescriptor setKeepDeletedCells(KeepDeletedCells keepDeletedCells) {</span> |
| <span class="source-line-no">949</span><span id="line-949"> return setValue(KEEP_DELETED_CELLS_BYTES, keepDeletedCells.name());</span> |
| <span class="source-line-no">950</span><span id="line-950"> }</span> |
| <span class="source-line-no">951</span><span id="line-951"></span> |
| <span class="source-line-no">952</span><span id="line-952"> /**</span> |
| <span class="source-line-no">953</span><span id="line-953"> * By default, HBase only consider timestamp in versions. So a previous Delete with higher ts</span> |
| <span class="source-line-no">954</span><span id="line-954"> * will mask a later Put with lower ts. Set this to true to enable new semantics of versions. We</span> |
| <span class="source-line-no">955</span><span id="line-955"> * will also consider mvcc in versions. See HBASE-15968 for details.</span> |
| <span class="source-line-no">956</span><span id="line-956"> */</span> |
| <span class="source-line-no">957</span><span id="line-957"> @Override</span> |
| <span class="source-line-no">958</span><span id="line-958"> public boolean isNewVersionBehavior() {</span> |
| <span class="source-line-no">959</span><span id="line-959"> return getStringOrDefault(NEW_VERSION_BEHAVIOR_BYTES, Boolean::parseBoolean,</span> |
| <span class="source-line-no">960</span><span id="line-960"> DEFAULT_NEW_VERSION_BEHAVIOR);</span> |
| <span class="source-line-no">961</span><span id="line-961"> }</span> |
| <span class="source-line-no">962</span><span id="line-962"></span> |
| <span class="source-line-no">963</span><span id="line-963"> public ModifyableColumnFamilyDescriptor setNewVersionBehavior(boolean newVersionBehavior) {</span> |
| <span class="source-line-no">964</span><span id="line-964"> return setValue(NEW_VERSION_BEHAVIOR_BYTES, Boolean.toString(newVersionBehavior));</span> |
| <span class="source-line-no">965</span><span id="line-965"> }</span> |
| <span class="source-line-no">966</span><span id="line-966"></span> |
| <span class="source-line-no">967</span><span id="line-967"> @Override</span> |
| <span class="source-line-no">968</span><span id="line-968"> public int getTimeToLive() {</span> |
| <span class="source-line-no">969</span><span id="line-969"> return getStringOrDefault(TTL_BYTES, Integer::parseInt, DEFAULT_TTL);</span> |
| <span class="source-line-no">970</span><span id="line-970"> }</span> |
| <span class="source-line-no">971</span><span id="line-971"></span> |
| <span class="source-line-no">972</span><span id="line-972"> /**</span> |
| <span class="source-line-no">973</span><span id="line-973"> * Set the time to live</span> |
| <span class="source-line-no">974</span><span id="line-974"> * @param timeToLive Time-to-live of cell contents, in seconds.</span> |
| <span class="source-line-no">975</span><span id="line-975"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">976</span><span id="line-976"> */</span> |
| <span class="source-line-no">977</span><span id="line-977"> public ModifyableColumnFamilyDescriptor setTimeToLive(int timeToLive) {</span> |
| <span class="source-line-no">978</span><span id="line-978"> return setValue(TTL_BYTES, Integer.toString(timeToLive));</span> |
| <span class="source-line-no">979</span><span id="line-979"> }</span> |
| <span class="source-line-no">980</span><span id="line-980"></span> |
| <span class="source-line-no">981</span><span id="line-981"> /**</span> |
| <span class="source-line-no">982</span><span id="line-982"> * Set the time to live</span> |
| <span class="source-line-no">983</span><span id="line-983"> * @param timeToLive Time-to-live of cell contents, in seconds.</span> |
| <span class="source-line-no">984</span><span id="line-984"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">985</span><span id="line-985"> * @throws org.apache.hadoop.hbase.exceptions.HBaseException exception</span> |
| <span class="source-line-no">986</span><span id="line-986"> */</span> |
| <span class="source-line-no">987</span><span id="line-987"> public ModifyableColumnFamilyDescriptor setTimeToLive(String timeToLive) throws HBaseException {</span> |
| <span class="source-line-no">988</span><span id="line-988"> return setTimeToLive(Integer.parseInt(PrettyPrinter.valueOf(timeToLive, Unit.TIME_INTERVAL)));</span> |
| <span class="source-line-no">989</span><span id="line-989"> }</span> |
| <span class="source-line-no">990</span><span id="line-990"></span> |
| <span class="source-line-no">991</span><span id="line-991"> @Override</span> |
| <span class="source-line-no">992</span><span id="line-992"> public int getMinVersions() {</span> |
| <span class="source-line-no">993</span><span id="line-993"> return getStringOrDefault(MIN_VERSIONS_BYTES, Integer::valueOf, DEFAULT_MIN_VERSIONS);</span> |
| <span class="source-line-no">994</span><span id="line-994"> }</span> |
| <span class="source-line-no">995</span><span id="line-995"></span> |
| <span class="source-line-no">996</span><span id="line-996"> /**</span> |
| <span class="source-line-no">997</span><span id="line-997"> * Set minimum versions to retain.</span> |
| <span class="source-line-no">998</span><span id="line-998"> * @param minVersions The minimum number of versions to keep. (used when timeToLive is set)</span> |
| <span class="source-line-no">999</span><span id="line-999"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1000</span><span id="line-1000"> */</span> |
| <span class="source-line-no">1001</span><span id="line-1001"> public ModifyableColumnFamilyDescriptor setMinVersions(int minVersions) {</span> |
| <span class="source-line-no">1002</span><span id="line-1002"> return setValue(MIN_VERSIONS_BYTES, Integer.toString(minVersions));</span> |
| <span class="source-line-no">1003</span><span id="line-1003"> }</span> |
| <span class="source-line-no">1004</span><span id="line-1004"></span> |
| <span class="source-line-no">1005</span><span id="line-1005"> /**</span> |
| <span class="source-line-no">1006</span><span id="line-1006"> * Retain all versions for a given TTL(retentionInterval), and then only a specific number of</span> |
| <span class="source-line-no">1007</span><span id="line-1007"> * versions(versionAfterInterval) after that interval elapses.</span> |
| <span class="source-line-no">1008</span><span id="line-1008"> * @param retentionInterval Retain all versions for this interval</span> |
| <span class="source-line-no">1009</span><span id="line-1009"> * @param versionAfterInterval Retain no of versions to retain after retentionInterval</span> |
| <span class="source-line-no">1010</span><span id="line-1010"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1011</span><span id="line-1011"> */</span> |
| <span class="source-line-no">1012</span><span id="line-1012"> public ModifyableColumnFamilyDescriptor setVersionsWithTimeToLive(final int retentionInterval,</span> |
| <span class="source-line-no">1013</span><span id="line-1013"> final int versionAfterInterval) {</span> |
| <span class="source-line-no">1014</span><span id="line-1014"> ModifyableColumnFamilyDescriptor modifyableColumnFamilyDescriptor =</span> |
| <span class="source-line-no">1015</span><span id="line-1015"> setVersions(versionAfterInterval, Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1016</span><span id="line-1016"> modifyableColumnFamilyDescriptor.setTimeToLive(retentionInterval);</span> |
| <span class="source-line-no">1017</span><span id="line-1017"> modifyableColumnFamilyDescriptor.setKeepDeletedCells(KeepDeletedCells.TTL);</span> |
| <span class="source-line-no">1018</span><span id="line-1018"> return modifyableColumnFamilyDescriptor;</span> |
| <span class="source-line-no">1019</span><span id="line-1019"> }</span> |
| <span class="source-line-no">1020</span><span id="line-1020"></span> |
| <span class="source-line-no">1021</span><span id="line-1021"> @Override</span> |
| <span class="source-line-no">1022</span><span id="line-1022"> public boolean isBlockCacheEnabled() {</span> |
| <span class="source-line-no">1023</span><span id="line-1023"> return getStringOrDefault(BLOCKCACHE_BYTES, Boolean::valueOf, DEFAULT_BLOCKCACHE);</span> |
| <span class="source-line-no">1024</span><span id="line-1024"> }</span> |
| <span class="source-line-no">1025</span><span id="line-1025"></span> |
| <span class="source-line-no">1026</span><span id="line-1026"> /**</span> |
| <span class="source-line-no">1027</span><span id="line-1027"> * Set the blockCacheEnabled flag</span> |
| <span class="source-line-no">1028</span><span id="line-1028"> * @param blockCacheEnabled True if hfile DATA type blocks should be cached (We always cache</span> |
| <span class="source-line-no">1029</span><span id="line-1029"> * INDEX and BLOOM blocks; you cannot turn this off).</span> |
| <span class="source-line-no">1030</span><span id="line-1030"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1031</span><span id="line-1031"> */</span> |
| <span class="source-line-no">1032</span><span id="line-1032"> public ModifyableColumnFamilyDescriptor setBlockCacheEnabled(boolean blockCacheEnabled) {</span> |
| <span class="source-line-no">1033</span><span id="line-1033"> return setValue(BLOCKCACHE_BYTES, Boolean.toString(blockCacheEnabled));</span> |
| <span class="source-line-no">1034</span><span id="line-1034"> }</span> |
| <span class="source-line-no">1035</span><span id="line-1035"></span> |
| <span class="source-line-no">1036</span><span id="line-1036"> @Override</span> |
| <span class="source-line-no">1037</span><span id="line-1037"> public BloomType getBloomFilterType() {</span> |
| <span class="source-line-no">1038</span><span id="line-1038"> return getStringOrDefault(BLOOMFILTER_BYTES, n -> BloomType.valueOf(n.toUpperCase()),</span> |
| <span class="source-line-no">1039</span><span id="line-1039"> DEFAULT_BLOOMFILTER);</span> |
| <span class="source-line-no">1040</span><span id="line-1040"> }</span> |
| <span class="source-line-no">1041</span><span id="line-1041"></span> |
| <span class="source-line-no">1042</span><span id="line-1042"> public ModifyableColumnFamilyDescriptor setBloomFilterType(final BloomType bt) {</span> |
| <span class="source-line-no">1043</span><span id="line-1043"> return setValue(BLOOMFILTER_BYTES, bt.name());</span> |
| <span class="source-line-no">1044</span><span id="line-1044"> }</span> |
| <span class="source-line-no">1045</span><span id="line-1045"></span> |
| <span class="source-line-no">1046</span><span id="line-1046"> @Override</span> |
| <span class="source-line-no">1047</span><span id="line-1047"> public int getScope() {</span> |
| <span class="source-line-no">1048</span><span id="line-1048"> return getStringOrDefault(REPLICATION_SCOPE_BYTES, Integer::valueOf,</span> |
| <span class="source-line-no">1049</span><span id="line-1049"> DEFAULT_REPLICATION_SCOPE);</span> |
| <span class="source-line-no">1050</span><span id="line-1050"> }</span> |
| <span class="source-line-no">1051</span><span id="line-1051"></span> |
| <span class="source-line-no">1052</span><span id="line-1052"> public ModifyableColumnFamilyDescriptor setScope(int scope) {</span> |
| <span class="source-line-no">1053</span><span id="line-1053"> return setValue(REPLICATION_SCOPE_BYTES, Integer.toString(scope));</span> |
| <span class="source-line-no">1054</span><span id="line-1054"> }</span> |
| <span class="source-line-no">1055</span><span id="line-1055"></span> |
| <span class="source-line-no">1056</span><span id="line-1056"> @Override</span> |
| <span class="source-line-no">1057</span><span id="line-1057"> public boolean isCacheDataOnWrite() {</span> |
| <span class="source-line-no">1058</span><span id="line-1058"> return getStringOrDefault(CACHE_DATA_ON_WRITE_BYTES, Boolean::valueOf,</span> |
| <span class="source-line-no">1059</span><span id="line-1059"> DEFAULT_CACHE_DATA_ON_WRITE);</span> |
| <span class="source-line-no">1060</span><span id="line-1060"> }</span> |
| <span class="source-line-no">1061</span><span id="line-1061"></span> |
| <span class="source-line-no">1062</span><span id="line-1062"> /**</span> |
| <span class="source-line-no">1063</span><span id="line-1063"> * Set the setCacheDataOnWrite flag</span> |
| <span class="source-line-no">1064</span><span id="line-1064"> * @param value true if we should cache data blocks on write</span> |
| <span class="source-line-no">1065</span><span id="line-1065"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1066</span><span id="line-1066"> */</span> |
| <span class="source-line-no">1067</span><span id="line-1067"> public ModifyableColumnFamilyDescriptor setCacheDataOnWrite(boolean value) {</span> |
| <span class="source-line-no">1068</span><span id="line-1068"> return setValue(CACHE_DATA_ON_WRITE_BYTES, Boolean.toString(value));</span> |
| <span class="source-line-no">1069</span><span id="line-1069"> }</span> |
| <span class="source-line-no">1070</span><span id="line-1070"></span> |
| <span class="source-line-no">1071</span><span id="line-1071"> @Override</span> |
| <span class="source-line-no">1072</span><span id="line-1072"> public boolean isCacheIndexesOnWrite() {</span> |
| <span class="source-line-no">1073</span><span id="line-1073"> return getStringOrDefault(CACHE_INDEX_ON_WRITE_BYTES, Boolean::valueOf,</span> |
| <span class="source-line-no">1074</span><span id="line-1074"> DEFAULT_CACHE_INDEX_ON_WRITE);</span> |
| <span class="source-line-no">1075</span><span id="line-1075"> }</span> |
| <span class="source-line-no">1076</span><span id="line-1076"></span> |
| <span class="source-line-no">1077</span><span id="line-1077"> /**</span> |
| <span class="source-line-no">1078</span><span id="line-1078"> * Set the setCacheIndexesOnWrite flag</span> |
| <span class="source-line-no">1079</span><span id="line-1079"> * @param value true if we should cache index blocks on write</span> |
| <span class="source-line-no">1080</span><span id="line-1080"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1081</span><span id="line-1081"> */</span> |
| <span class="source-line-no">1082</span><span id="line-1082"> public ModifyableColumnFamilyDescriptor setCacheIndexesOnWrite(boolean value) {</span> |
| <span class="source-line-no">1083</span><span id="line-1083"> return setValue(CACHE_INDEX_ON_WRITE_BYTES, Boolean.toString(value));</span> |
| <span class="source-line-no">1084</span><span id="line-1084"> }</span> |
| <span class="source-line-no">1085</span><span id="line-1085"></span> |
| <span class="source-line-no">1086</span><span id="line-1086"> @Override</span> |
| <span class="source-line-no">1087</span><span id="line-1087"> public boolean isCacheBloomsOnWrite() {</span> |
| <span class="source-line-no">1088</span><span id="line-1088"> return getStringOrDefault(CACHE_BLOOMS_ON_WRITE_BYTES, Boolean::valueOf,</span> |
| <span class="source-line-no">1089</span><span id="line-1089"> DEFAULT_CACHE_BLOOMS_ON_WRITE);</span> |
| <span class="source-line-no">1090</span><span id="line-1090"> }</span> |
| <span class="source-line-no">1091</span><span id="line-1091"></span> |
| <span class="source-line-no">1092</span><span id="line-1092"> /**</span> |
| <span class="source-line-no">1093</span><span id="line-1093"> * Set the setCacheBloomsOnWrite flag.</span> |
| <span class="source-line-no">1094</span><span id="line-1094"> * @param value true if we should cache bloomfilter blocks on write</span> |
| <span class="source-line-no">1095</span><span id="line-1095"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1096</span><span id="line-1096"> */</span> |
| <span class="source-line-no">1097</span><span id="line-1097"> public ModifyableColumnFamilyDescriptor setCacheBloomsOnWrite(boolean value) {</span> |
| <span class="source-line-no">1098</span><span id="line-1098"> return setValue(CACHE_BLOOMS_ON_WRITE_BYTES, Boolean.toString(value));</span> |
| <span class="source-line-no">1099</span><span id="line-1099"> }</span> |
| <span class="source-line-no">1100</span><span id="line-1100"></span> |
| <span class="source-line-no">1101</span><span id="line-1101"> @Override</span> |
| <span class="source-line-no">1102</span><span id="line-1102"> public boolean isEvictBlocksOnClose() {</span> |
| <span class="source-line-no">1103</span><span id="line-1103"> return getStringOrDefault(EVICT_BLOCKS_ON_CLOSE_BYTES, Boolean::valueOf,</span> |
| <span class="source-line-no">1104</span><span id="line-1104"> DEFAULT_EVICT_BLOCKS_ON_CLOSE);</span> |
| <span class="source-line-no">1105</span><span id="line-1105"> }</span> |
| <span class="source-line-no">1106</span><span id="line-1106"></span> |
| <span class="source-line-no">1107</span><span id="line-1107"> /**</span> |
| <span class="source-line-no">1108</span><span id="line-1108"> * Set the setEvictBlocksOnClose flag.</span> |
| <span class="source-line-no">1109</span><span id="line-1109"> * @param value true if we should evict cached blocks from the blockcache on close</span> |
| <span class="source-line-no">1110</span><span id="line-1110"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1111</span><span id="line-1111"> */</span> |
| <span class="source-line-no">1112</span><span id="line-1112"> public ModifyableColumnFamilyDescriptor setEvictBlocksOnClose(boolean value) {</span> |
| <span class="source-line-no">1113</span><span id="line-1113"> return setValue(EVICT_BLOCKS_ON_CLOSE_BYTES, Boolean.toString(value));</span> |
| <span class="source-line-no">1114</span><span id="line-1114"> }</span> |
| <span class="source-line-no">1115</span><span id="line-1115"></span> |
| <span class="source-line-no">1116</span><span id="line-1116"> @Override</span> |
| <span class="source-line-no">1117</span><span id="line-1117"> public boolean isPrefetchBlocksOnOpen() {</span> |
| <span class="source-line-no">1118</span><span id="line-1118"> return getStringOrDefault(PREFETCH_BLOCKS_ON_OPEN_BYTES, Boolean::valueOf,</span> |
| <span class="source-line-no">1119</span><span id="line-1119"> DEFAULT_PREFETCH_BLOCKS_ON_OPEN);</span> |
| <span class="source-line-no">1120</span><span id="line-1120"> }</span> |
| <span class="source-line-no">1121</span><span id="line-1121"></span> |
| <span class="source-line-no">1122</span><span id="line-1122"> /**</span> |
| <span class="source-line-no">1123</span><span id="line-1123"> * Set the setPrefetchBlocksOnOpen flag</span> |
| <span class="source-line-no">1124</span><span id="line-1124"> * @param value true if we should prefetch blocks into the blockcache on open</span> |
| <span class="source-line-no">1125</span><span id="line-1125"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1126</span><span id="line-1126"> */</span> |
| <span class="source-line-no">1127</span><span id="line-1127"> public ModifyableColumnFamilyDescriptor setPrefetchBlocksOnOpen(boolean value) {</span> |
| <span class="source-line-no">1128</span><span id="line-1128"> return setValue(PREFETCH_BLOCKS_ON_OPEN_BYTES, Boolean.toString(value));</span> |
| <span class="source-line-no">1129</span><span id="line-1129"> }</span> |
| <span class="source-line-no">1130</span><span id="line-1130"></span> |
| <span class="source-line-no">1131</span><span id="line-1131"> @Override</span> |
| <span class="source-line-no">1132</span><span id="line-1132"> public String toString() {</span> |
| <span class="source-line-no">1133</span><span id="line-1133"> StringBuilder s = new StringBuilder();</span> |
| <span class="source-line-no">1134</span><span id="line-1134"> s.append('{');</span> |
| <span class="source-line-no">1135</span><span id="line-1135"> s.append(HConstants.NAME);</span> |
| <span class="source-line-no">1136</span><span id="line-1136"> s.append(" => '");</span> |
| <span class="source-line-no">1137</span><span id="line-1137"> s.append(getNameAsString());</span> |
| <span class="source-line-no">1138</span><span id="line-1138"> s.append("'");</span> |
| <span class="source-line-no">1139</span><span id="line-1139"> s.append(getValues(true));</span> |
| <span class="source-line-no">1140</span><span id="line-1140"> s.append('}');</span> |
| <span class="source-line-no">1141</span><span id="line-1141"> return s.toString();</span> |
| <span class="source-line-no">1142</span><span id="line-1142"> }</span> |
| <span class="source-line-no">1143</span><span id="line-1143"></span> |
| <span class="source-line-no">1144</span><span id="line-1144"> @Override</span> |
| <span class="source-line-no">1145</span><span id="line-1145"> public String toStringCustomizedValues() {</span> |
| <span class="source-line-no">1146</span><span id="line-1146"> StringBuilder s = new StringBuilder();</span> |
| <span class="source-line-no">1147</span><span id="line-1147"> s.append('{');</span> |
| <span class="source-line-no">1148</span><span id="line-1148"> s.append(HConstants.NAME);</span> |
| <span class="source-line-no">1149</span><span id="line-1149"> s.append(" => '");</span> |
| <span class="source-line-no">1150</span><span id="line-1150"> s.append(getNameAsString());</span> |
| <span class="source-line-no">1151</span><span id="line-1151"> s.append("'");</span> |
| <span class="source-line-no">1152</span><span id="line-1152"> s.append(getValues(false));</span> |
| <span class="source-line-no">1153</span><span id="line-1153"> s.append('}');</span> |
| <span class="source-line-no">1154</span><span id="line-1154"> return s.toString();</span> |
| <span class="source-line-no">1155</span><span id="line-1155"> }</span> |
| <span class="source-line-no">1156</span><span id="line-1156"></span> |
| <span class="source-line-no">1157</span><span id="line-1157"> private StringBuilder getValues(boolean printDefaults) {</span> |
| <span class="source-line-no">1158</span><span id="line-1158"> StringBuilder s = new StringBuilder();</span> |
| <span class="source-line-no">1159</span><span id="line-1159"></span> |
| <span class="source-line-no">1160</span><span id="line-1160"> boolean hasConfigKeys = false;</span> |
| <span class="source-line-no">1161</span><span id="line-1161"></span> |
| <span class="source-line-no">1162</span><span id="line-1162"> // print all reserved keys first</span> |
| <span class="source-line-no">1163</span><span id="line-1163"> for (Map.Entry<Bytes, Bytes> entry : values.entrySet()) {</span> |
| <span class="source-line-no">1164</span><span id="line-1164"> if (!RESERVED_KEYWORDS.contains(entry.getKey())) {</span> |
| <span class="source-line-no">1165</span><span id="line-1165"> hasConfigKeys = true;</span> |
| <span class="source-line-no">1166</span><span id="line-1166"> continue;</span> |
| <span class="source-line-no">1167</span><span id="line-1167"> }</span> |
| <span class="source-line-no">1168</span><span id="line-1168"> String key = Bytes.toString(entry.getKey().get());</span> |
| <span class="source-line-no">1169</span><span id="line-1169"> String value = Bytes.toStringBinary(entry.getValue().get());</span> |
| <span class="source-line-no">1170</span><span id="line-1170"> if (</span> |
| <span class="source-line-no">1171</span><span id="line-1171"> printDefaults || !DEFAULT_VALUES.containsKey(key)</span> |
| <span class="source-line-no">1172</span><span id="line-1172"> || !DEFAULT_VALUES.get(key).equalsIgnoreCase(value)</span> |
| <span class="source-line-no">1173</span><span id="line-1173"> ) {</span> |
| <span class="source-line-no">1174</span><span id="line-1174"> s.append(", ");</span> |
| <span class="source-line-no">1175</span><span id="line-1175"> s.append(key);</span> |
| <span class="source-line-no">1176</span><span id="line-1176"> s.append(" => ");</span> |
| <span class="source-line-no">1177</span><span id="line-1177"> s.append('\'').append(PrettyPrinter.format(value, getUnit(key))).append('\'');</span> |
| <span class="source-line-no">1178</span><span id="line-1178"> }</span> |
| <span class="source-line-no">1179</span><span id="line-1179"> }</span> |
| <span class="source-line-no">1180</span><span id="line-1180"></span> |
| <span class="source-line-no">1181</span><span id="line-1181"> // print all non-reserved, advanced config keys as a separate subset</span> |
| <span class="source-line-no">1182</span><span id="line-1182"> if (hasConfigKeys) {</span> |
| <span class="source-line-no">1183</span><span id="line-1183"> s.append(", ");</span> |
| <span class="source-line-no">1184</span><span id="line-1184"> s.append(HConstants.METADATA).append(" => ");</span> |
| <span class="source-line-no">1185</span><span id="line-1185"> s.append('{');</span> |
| <span class="source-line-no">1186</span><span id="line-1186"> boolean printComma = false;</span> |
| <span class="source-line-no">1187</span><span id="line-1187"> for (Map.Entry<Bytes, Bytes> entry : values.entrySet()) {</span> |
| <span class="source-line-no">1188</span><span id="line-1188"> Bytes k = entry.getKey();</span> |
| <span class="source-line-no">1189</span><span id="line-1189"> if (RESERVED_KEYWORDS.contains(k)) {</span> |
| <span class="source-line-no">1190</span><span id="line-1190"> continue;</span> |
| <span class="source-line-no">1191</span><span id="line-1191"> }</span> |
| <span class="source-line-no">1192</span><span id="line-1192"> String key = Bytes.toString(k.get());</span> |
| <span class="source-line-no">1193</span><span id="line-1193"> String value = Bytes.toStringBinary(entry.getValue().get());</span> |
| <span class="source-line-no">1194</span><span id="line-1194"> if (printComma) {</span> |
| <span class="source-line-no">1195</span><span id="line-1195"> s.append(", ");</span> |
| <span class="source-line-no">1196</span><span id="line-1196"> }</span> |
| <span class="source-line-no">1197</span><span id="line-1197"> printComma = true;</span> |
| <span class="source-line-no">1198</span><span id="line-1198"> s.append('\'').append(key).append('\'');</span> |
| <span class="source-line-no">1199</span><span id="line-1199"> s.append(" => ");</span> |
| <span class="source-line-no">1200</span><span id="line-1200"> s.append('\'').append(PrettyPrinter.format(value, getUnit(key))).append('\'');</span> |
| <span class="source-line-no">1201</span><span id="line-1201"> }</span> |
| <span class="source-line-no">1202</span><span id="line-1202"> s.append('}');</span> |
| <span class="source-line-no">1203</span><span id="line-1203"> }</span> |
| <span class="source-line-no">1204</span><span id="line-1204"></span> |
| <span class="source-line-no">1205</span><span id="line-1205"> if (!configuration.isEmpty()) {</span> |
| <span class="source-line-no">1206</span><span id="line-1206"> s.append(", ");</span> |
| <span class="source-line-no">1207</span><span id="line-1207"> s.append(HConstants.CONFIGURATION).append(" => ");</span> |
| <span class="source-line-no">1208</span><span id="line-1208"> s.append('{');</span> |
| <span class="source-line-no">1209</span><span id="line-1209"> boolean printCommaForConfiguration = false;</span> |
| <span class="source-line-no">1210</span><span id="line-1210"> for (Map.Entry<String, String> e : configuration.entrySet()) {</span> |
| <span class="source-line-no">1211</span><span id="line-1211"> if (printCommaForConfiguration) {</span> |
| <span class="source-line-no">1212</span><span id="line-1212"> s.append(", ");</span> |
| <span class="source-line-no">1213</span><span id="line-1213"> }</span> |
| <span class="source-line-no">1214</span><span id="line-1214"> printCommaForConfiguration = true;</span> |
| <span class="source-line-no">1215</span><span id="line-1215"> s.append('\'').append(e.getKey()).append('\'');</span> |
| <span class="source-line-no">1216</span><span id="line-1216"> s.append(" => ");</span> |
| <span class="source-line-no">1217</span><span id="line-1217"> s.append('\'').append(PrettyPrinter.format(e.getValue(), getUnit(e.getKey())))</span> |
| <span class="source-line-no">1218</span><span id="line-1218"> .append('\'');</span> |
| <span class="source-line-no">1219</span><span id="line-1219"> }</span> |
| <span class="source-line-no">1220</span><span id="line-1220"> s.append("}");</span> |
| <span class="source-line-no">1221</span><span id="line-1221"> }</span> |
| <span class="source-line-no">1222</span><span id="line-1222"> return s;</span> |
| <span class="source-line-no">1223</span><span id="line-1223"> }</span> |
| <span class="source-line-no">1224</span><span id="line-1224"></span> |
| <span class="source-line-no">1225</span><span id="line-1225"> @Override</span> |
| <span class="source-line-no">1226</span><span id="line-1226"> public boolean equals(Object obj) {</span> |
| <span class="source-line-no">1227</span><span id="line-1227"> if (this == obj) {</span> |
| <span class="source-line-no">1228</span><span id="line-1228"> return true;</span> |
| <span class="source-line-no">1229</span><span id="line-1229"> }</span> |
| <span class="source-line-no">1230</span><span id="line-1230"> if (obj instanceof ModifyableColumnFamilyDescriptor) {</span> |
| <span class="source-line-no">1231</span><span id="line-1231"> return ColumnFamilyDescriptor.COMPARATOR.compare(this,</span> |
| <span class="source-line-no">1232</span><span id="line-1232"> (ModifyableColumnFamilyDescriptor) obj) == 0;</span> |
| <span class="source-line-no">1233</span><span id="line-1233"> }</span> |
| <span class="source-line-no">1234</span><span id="line-1234"> return false;</span> |
| <span class="source-line-no">1235</span><span id="line-1235"> }</span> |
| <span class="source-line-no">1236</span><span id="line-1236"></span> |
| <span class="source-line-no">1237</span><span id="line-1237"> @Override</span> |
| <span class="source-line-no">1238</span><span id="line-1238"> public int hashCode() {</span> |
| <span class="source-line-no">1239</span><span id="line-1239"> int result = Bytes.hashCode(name);</span> |
| <span class="source-line-no">1240</span><span id="line-1240"> result ^= (int) COLUMN_DESCRIPTOR_VERSION;</span> |
| <span class="source-line-no">1241</span><span id="line-1241"> result ^= values.hashCode();</span> |
| <span class="source-line-no">1242</span><span id="line-1242"> result ^= configuration.hashCode();</span> |
| <span class="source-line-no">1243</span><span id="line-1243"> return result;</span> |
| <span class="source-line-no">1244</span><span id="line-1244"> }</span> |
| <span class="source-line-no">1245</span><span id="line-1245"></span> |
| <span class="source-line-no">1246</span><span id="line-1246"> @Override</span> |
| <span class="source-line-no">1247</span><span id="line-1247"> public int compareTo(ModifyableColumnFamilyDescriptor other) {</span> |
| <span class="source-line-no">1248</span><span id="line-1248"> return COMPARATOR.compare(this, other);</span> |
| <span class="source-line-no">1249</span><span id="line-1249"> }</span> |
| <span class="source-line-no">1250</span><span id="line-1250"></span> |
| <span class="source-line-no">1251</span><span id="line-1251"> /** Returns This instance serialized with pb with pb magic prefix */</span> |
| <span class="source-line-no">1252</span><span id="line-1252"> private byte[] toByteArray() {</span> |
| <span class="source-line-no">1253</span><span id="line-1253"> return ProtobufUtil.prependPBMagic(ProtobufUtil.toColumnFamilySchema(this).toByteArray());</span> |
| <span class="source-line-no">1254</span><span id="line-1254"> }</span> |
| <span class="source-line-no">1255</span><span id="line-1255"></span> |
| <span class="source-line-no">1256</span><span id="line-1256"> /**</span> |
| <span class="source-line-no">1257</span><span id="line-1257"> * Parse the serialized representation of a {@link ModifyableColumnFamilyDescriptor}</span> |
| <span class="source-line-no">1258</span><span id="line-1258"> * @param bytes A pb serialized {@link ModifyableColumnFamilyDescriptor} instance with pb magic</span> |
| <span class="source-line-no">1259</span><span id="line-1259"> * prefix</span> |
| <span class="source-line-no">1260</span><span id="line-1260"> * @return An instance of {@link ModifyableColumnFamilyDescriptor} made from <code>bytes</code></span> |
| <span class="source-line-no">1261</span><span id="line-1261"> * @see #toByteArray()</span> |
| <span class="source-line-no">1262</span><span id="line-1262"> */</span> |
| <span class="source-line-no">1263</span><span id="line-1263"> private static ColumnFamilyDescriptor parseFrom(final byte[] bytes)</span> |
| <span class="source-line-no">1264</span><span id="line-1264"> throws DeserializationException {</span> |
| <span class="source-line-no">1265</span><span id="line-1265"> if (!ProtobufUtil.isPBMagicPrefix(bytes)) {</span> |
| <span class="source-line-no">1266</span><span id="line-1266"> throw new DeserializationException("No magic");</span> |
| <span class="source-line-no">1267</span><span id="line-1267"> }</span> |
| <span class="source-line-no">1268</span><span id="line-1268"> int pblen = ProtobufUtil.lengthOfPBMagic();</span> |
| <span class="source-line-no">1269</span><span id="line-1269"> ColumnFamilySchema.Builder builder = ColumnFamilySchema.newBuilder();</span> |
| <span class="source-line-no">1270</span><span id="line-1270"> ColumnFamilySchema cfs = null;</span> |
| <span class="source-line-no">1271</span><span id="line-1271"> try {</span> |
| <span class="source-line-no">1272</span><span id="line-1272"> ProtobufUtil.mergeFrom(builder, bytes, pblen, bytes.length - pblen);</span> |
| <span class="source-line-no">1273</span><span id="line-1273"> cfs = builder.build();</span> |
| <span class="source-line-no">1274</span><span id="line-1274"> } catch (IOException e) {</span> |
| <span class="source-line-no">1275</span><span id="line-1275"> throw new DeserializationException(e);</span> |
| <span class="source-line-no">1276</span><span id="line-1276"> }</span> |
| <span class="source-line-no">1277</span><span id="line-1277"> return ProtobufUtil.toColumnFamilyDescriptor(cfs);</span> |
| <span class="source-line-no">1278</span><span id="line-1278"> }</span> |
| <span class="source-line-no">1279</span><span id="line-1279"></span> |
| <span class="source-line-no">1280</span><span id="line-1280"> @Override</span> |
| <span class="source-line-no">1281</span><span id="line-1281"> public String getConfigurationValue(String key) {</span> |
| <span class="source-line-no">1282</span><span id="line-1282"> return configuration.get(key);</span> |
| <span class="source-line-no">1283</span><span id="line-1283"> }</span> |
| <span class="source-line-no">1284</span><span id="line-1284"></span> |
| <span class="source-line-no">1285</span><span id="line-1285"> @Override</span> |
| <span class="source-line-no">1286</span><span id="line-1286"> public Map<String, String> getConfiguration() {</span> |
| <span class="source-line-no">1287</span><span id="line-1287"> // shallow pointer copy</span> |
| <span class="source-line-no">1288</span><span id="line-1288"> return Collections.unmodifiableMap(configuration);</span> |
| <span class="source-line-no">1289</span><span id="line-1289"> }</span> |
| <span class="source-line-no">1290</span><span id="line-1290"></span> |
| <span class="source-line-no">1291</span><span id="line-1291"> /**</span> |
| <span class="source-line-no">1292</span><span id="line-1292"> * Setter for storing a configuration setting in {@link #configuration} map.</span> |
| <span class="source-line-no">1293</span><span id="line-1293"> * @param key Config key. Same as XML config key e.g. hbase.something.or.other.</span> |
| <span class="source-line-no">1294</span><span id="line-1294"> * @param value String value. If null, removes the configuration.</span> |
| <span class="source-line-no">1295</span><span id="line-1295"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1296</span><span id="line-1296"> */</span> |
| <span class="source-line-no">1297</span><span id="line-1297"> public ModifyableColumnFamilyDescriptor setConfiguration(String key, String value) {</span> |
| <span class="source-line-no">1298</span><span id="line-1298"> if (value == null || value.length() == 0) {</span> |
| <span class="source-line-no">1299</span><span id="line-1299"> configuration.remove(key);</span> |
| <span class="source-line-no">1300</span><span id="line-1300"> } else {</span> |
| <span class="source-line-no">1301</span><span id="line-1301"> configuration.put(key, value);</span> |
| <span class="source-line-no">1302</span><span id="line-1302"> }</span> |
| <span class="source-line-no">1303</span><span id="line-1303"> return this;</span> |
| <span class="source-line-no">1304</span><span id="line-1304"> }</span> |
| <span class="source-line-no">1305</span><span id="line-1305"></span> |
| <span class="source-line-no">1306</span><span id="line-1306"> /**</span> |
| <span class="source-line-no">1307</span><span id="line-1307"> * Remove a configuration setting represented by the key from the {@link #configuration} map.</span> |
| <span class="source-line-no">1308</span><span id="line-1308"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1309</span><span id="line-1309"> */</span> |
| <span class="source-line-no">1310</span><span id="line-1310"> public ModifyableColumnFamilyDescriptor removeConfiguration(final String key) {</span> |
| <span class="source-line-no">1311</span><span id="line-1311"> return setConfiguration(key, null);</span> |
| <span class="source-line-no">1312</span><span id="line-1312"> }</span> |
| <span class="source-line-no">1313</span><span id="line-1313"></span> |
| <span class="source-line-no">1314</span><span id="line-1314"> @Override</span> |
| <span class="source-line-no">1315</span><span id="line-1315"> public String getEncryptionType() {</span> |
| <span class="source-line-no">1316</span><span id="line-1316"> return getStringOrDefault(ENCRYPTION_BYTES, Function.identity(), null);</span> |
| <span class="source-line-no">1317</span><span id="line-1317"> }</span> |
| <span class="source-line-no">1318</span><span id="line-1318"></span> |
| <span class="source-line-no">1319</span><span id="line-1319"> /**</span> |
| <span class="source-line-no">1320</span><span id="line-1320"> * Set the encryption algorithm for use with this family</span> |
| <span class="source-line-no">1321</span><span id="line-1321"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1322</span><span id="line-1322"> */</span> |
| <span class="source-line-no">1323</span><span id="line-1323"> public ModifyableColumnFamilyDescriptor setEncryptionType(String algorithm) {</span> |
| <span class="source-line-no">1324</span><span id="line-1324"> return setValue(ENCRYPTION_BYTES, algorithm);</span> |
| <span class="source-line-no">1325</span><span id="line-1325"> }</span> |
| <span class="source-line-no">1326</span><span id="line-1326"></span> |
| <span class="source-line-no">1327</span><span id="line-1327"> @Override</span> |
| <span class="source-line-no">1328</span><span id="line-1328"> public byte[] getEncryptionKey() {</span> |
| <span class="source-line-no">1329</span><span id="line-1329"> return getOrDefault(ENCRYPTION_KEY_BYTES, Bytes::copy, null);</span> |
| <span class="source-line-no">1330</span><span id="line-1330"> }</span> |
| <span class="source-line-no">1331</span><span id="line-1331"></span> |
| <span class="source-line-no">1332</span><span id="line-1332"> /**</span> |
| <span class="source-line-no">1333</span><span id="line-1333"> * Set the raw crypto key attribute for the family</span> |
| <span class="source-line-no">1334</span><span id="line-1334"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1335</span><span id="line-1335"> */</span> |
| <span class="source-line-no">1336</span><span id="line-1336"> public ModifyableColumnFamilyDescriptor setEncryptionKey(byte[] keyBytes) {</span> |
| <span class="source-line-no">1337</span><span id="line-1337"> return setValue(ENCRYPTION_KEY_BYTES, new Bytes(keyBytes));</span> |
| <span class="source-line-no">1338</span><span id="line-1338"> }</span> |
| <span class="source-line-no">1339</span><span id="line-1339"></span> |
| <span class="source-line-no">1340</span><span id="line-1340"> @Override</span> |
| <span class="source-line-no">1341</span><span id="line-1341"> public long getMobThreshold() {</span> |
| <span class="source-line-no">1342</span><span id="line-1342"> return getStringOrDefault(MOB_THRESHOLD_BYTES, Long::valueOf, DEFAULT_MOB_THRESHOLD);</span> |
| <span class="source-line-no">1343</span><span id="line-1343"> }</span> |
| <span class="source-line-no">1344</span><span id="line-1344"></span> |
| <span class="source-line-no">1345</span><span id="line-1345"> /**</span> |
| <span class="source-line-no">1346</span><span id="line-1346"> * Sets the mob threshold of the family.</span> |
| <span class="source-line-no">1347</span><span id="line-1347"> * @param threshold The mob threshold.</span> |
| <span class="source-line-no">1348</span><span id="line-1348"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1349</span><span id="line-1349"> */</span> |
| <span class="source-line-no">1350</span><span id="line-1350"> public ModifyableColumnFamilyDescriptor setMobThreshold(long threshold) {</span> |
| <span class="source-line-no">1351</span><span id="line-1351"> return setValue(MOB_THRESHOLD_BYTES, String.valueOf(threshold));</span> |
| <span class="source-line-no">1352</span><span id="line-1352"> }</span> |
| <span class="source-line-no">1353</span><span id="line-1353"></span> |
| <span class="source-line-no">1354</span><span id="line-1354"> @Override</span> |
| <span class="source-line-no">1355</span><span id="line-1355"> public boolean isMobEnabled() {</span> |
| <span class="source-line-no">1356</span><span id="line-1356"> return getStringOrDefault(IS_MOB_BYTES, Boolean::valueOf, DEFAULT_MOB);</span> |
| <span class="source-line-no">1357</span><span id="line-1357"> }</span> |
| <span class="source-line-no">1358</span><span id="line-1358"></span> |
| <span class="source-line-no">1359</span><span id="line-1359"> /**</span> |
| <span class="source-line-no">1360</span><span id="line-1360"> * Enables the mob for the family.</span> |
| <span class="source-line-no">1361</span><span id="line-1361"> * @param isMobEnabled Whether to enable the mob for the family.</span> |
| <span class="source-line-no">1362</span><span id="line-1362"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1363</span><span id="line-1363"> */</span> |
| <span class="source-line-no">1364</span><span id="line-1364"> public ModifyableColumnFamilyDescriptor setMobEnabled(boolean isMobEnabled) {</span> |
| <span class="source-line-no">1365</span><span id="line-1365"> return setValue(IS_MOB_BYTES, String.valueOf(isMobEnabled));</span> |
| <span class="source-line-no">1366</span><span id="line-1366"> }</span> |
| <span class="source-line-no">1367</span><span id="line-1367"></span> |
| <span class="source-line-no">1368</span><span id="line-1368"> @Override</span> |
| <span class="source-line-no">1369</span><span id="line-1369"> public MobCompactPartitionPolicy getMobCompactPartitionPolicy() {</span> |
| <span class="source-line-no">1370</span><span id="line-1370"> return getStringOrDefault(MOB_COMPACT_PARTITION_POLICY_BYTES,</span> |
| <span class="source-line-no">1371</span><span id="line-1371"> n -> MobCompactPartitionPolicy.valueOf(n.toUpperCase()),</span> |
| <span class="source-line-no">1372</span><span id="line-1372"> DEFAULT_MOB_COMPACT_PARTITION_POLICY);</span> |
| <span class="source-line-no">1373</span><span id="line-1373"> }</span> |
| <span class="source-line-no">1374</span><span id="line-1374"></span> |
| <span class="source-line-no">1375</span><span id="line-1375"> /**</span> |
| <span class="source-line-no">1376</span><span id="line-1376"> * Set the mob compact partition policy for the family.</span> |
| <span class="source-line-no">1377</span><span id="line-1377"> * @param policy policy type</span> |
| <span class="source-line-no">1378</span><span id="line-1378"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1379</span><span id="line-1379"> */</span> |
| <span class="source-line-no">1380</span><span id="line-1380"> public ModifyableColumnFamilyDescriptor</span> |
| <span class="source-line-no">1381</span><span id="line-1381"> setMobCompactPartitionPolicy(MobCompactPartitionPolicy policy) {</span> |
| <span class="source-line-no">1382</span><span id="line-1382"> return setValue(MOB_COMPACT_PARTITION_POLICY_BYTES, policy.name());</span> |
| <span class="source-line-no">1383</span><span id="line-1383"> }</span> |
| <span class="source-line-no">1384</span><span id="line-1384"></span> |
| <span class="source-line-no">1385</span><span id="line-1385"> @Override</span> |
| <span class="source-line-no">1386</span><span id="line-1386"> public short getDFSReplication() {</span> |
| <span class="source-line-no">1387</span><span id="line-1387"> return getStringOrDefault(DFS_REPLICATION_BYTES, Short::valueOf, DEFAULT_DFS_REPLICATION);</span> |
| <span class="source-line-no">1388</span><span id="line-1388"> }</span> |
| <span class="source-line-no">1389</span><span id="line-1389"></span> |
| <span class="source-line-no">1390</span><span id="line-1390"> /**</span> |
| <span class="source-line-no">1391</span><span id="line-1391"> * Set the replication factor to hfile(s) belonging to this family</span> |
| <span class="source-line-no">1392</span><span id="line-1392"> * @param replication number of replicas the blocks(s) belonging to this CF should have, or</span> |
| <span class="source-line-no">1393</span><span id="line-1393"> * {@link #DEFAULT_DFS_REPLICATION} for the default replication factor set in</span> |
| <span class="source-line-no">1394</span><span id="line-1394"> * the filesystem</span> |
| <span class="source-line-no">1395</span><span id="line-1395"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1396</span><span id="line-1396"> */</span> |
| <span class="source-line-no">1397</span><span id="line-1397"> public ModifyableColumnFamilyDescriptor setDFSReplication(short replication) {</span> |
| <span class="source-line-no">1398</span><span id="line-1398"> if (replication < 1 && replication != DEFAULT_DFS_REPLICATION) {</span> |
| <span class="source-line-no">1399</span><span id="line-1399"> throw new IllegalArgumentException(</span> |
| <span class="source-line-no">1400</span><span id="line-1400"> "DFS replication factor cannot be less than 1 if explicitly set.");</span> |
| <span class="source-line-no">1401</span><span id="line-1401"> }</span> |
| <span class="source-line-no">1402</span><span id="line-1402"> return setValue(DFS_REPLICATION_BYTES, Short.toString(replication));</span> |
| <span class="source-line-no">1403</span><span id="line-1403"> }</span> |
| <span class="source-line-no">1404</span><span id="line-1404"></span> |
| <span class="source-line-no">1405</span><span id="line-1405"> @Override</span> |
| <span class="source-line-no">1406</span><span id="line-1406"> public String getStoragePolicy() {</span> |
| <span class="source-line-no">1407</span><span id="line-1407"> return getStringOrDefault(STORAGE_POLICY_BYTES, Function.identity(), null);</span> |
| <span class="source-line-no">1408</span><span id="line-1408"> }</span> |
| <span class="source-line-no">1409</span><span id="line-1409"></span> |
| <span class="source-line-no">1410</span><span id="line-1410"> /**</span> |
| <span class="source-line-no">1411</span><span id="line-1411"> * Set the storage policy for use with this family</span> |
| <span class="source-line-no">1412</span><span id="line-1412"> * @param policy the policy to set, valid setting includes: <i>"LAZY_PERSIST"</i>,</span> |
| <span class="source-line-no">1413</span><span id="line-1413"> * <i>"ALL_SSD"</i>, <i>"ONE_SSD"</i>, <i>"HOT"</i>, <i>"WARM"</i>, <i>"COLD"</i></span> |
| <span class="source-line-no">1414</span><span id="line-1414"> * @return this (for chained invocation)</span> |
| <span class="source-line-no">1415</span><span id="line-1415"> */</span> |
| <span class="source-line-no">1416</span><span id="line-1416"> public ModifyableColumnFamilyDescriptor setStoragePolicy(String policy) {</span> |
| <span class="source-line-no">1417</span><span id="line-1417"> return setValue(STORAGE_POLICY_BYTES, policy);</span> |
| <span class="source-line-no">1418</span><span id="line-1418"> }</span> |
| <span class="source-line-no">1419</span><span id="line-1419"></span> |
| <span class="source-line-no">1420</span><span id="line-1420"> }</span> |
| <span class="source-line-no">1421</span><span id="line-1421">}</span> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| </pre> |
| </div> |
| </main> |
| </body> |
| </html> |
