diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/regionserver/BloomType.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/regionserver/BloomType.java index c0b2dd20412..eec665c4f04 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/regionserver/BloomType.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/regionserver/BloomType.java @@ -38,9 +38,5 @@ public enum BloomType { /** * Bloom enabled with Table row prefix as Key, specify the length of the prefix */ - ROWPREFIX_FIXED_LENGTH, - /** - * Bloom enabled with Table row prefix as Key, specify the delimiter of the prefix - */ - ROWPREFIX_DELIMITED + ROWPREFIX_FIXED_LENGTH } diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java index 4faf05df98c..55faccf2226 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/ChangeBloomFilterAction.java @@ -56,8 +56,6 @@ public class ChangeBloomFilterAction extends Action { columnBuilder.setBloomFilterType(bloomType); if (bloomType == BloomType.ROWPREFIX_FIXED_LENGTH) { columnBuilder.setConfiguration(BloomFilterUtil.PREFIX_LENGTH_KEY, "10"); - } else if (bloomType == BloomType.ROWPREFIX_DELIMITED) { - columnBuilder.setConfiguration(BloomFilterUtil.DELIMITER_KEY, "#"); } }); diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java index 274a5066880..bac36189598 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java @@ -406,8 +406,6 @@ public class HFileOutputFormat2 String bloomParam = bloomParamMap.get(tableAndFamily); if (bloomType == BloomType.ROWPREFIX_FIXED_LENGTH) { conf.set(BloomFilterUtil.PREFIX_LENGTH_KEY, bloomParam); - } else if (bloomType == BloomType.ROWPREFIX_DELIMITED) { - conf.set(BloomFilterUtil.DELIMITER_KEY, bloomParam); } Integer blockSize = blockSizeMap.get(tableAndFamily); blockSize = blockSize == null ? HConstants.DEFAULT_BLOCKSIZE : blockSize; @@ -951,8 +949,6 @@ public class HFileOutputFormat2 String bloomParam = ""; if (bloomType == BloomType.ROWPREFIX_FIXED_LENGTH) { bloomParam = familyDescriptor.getConfigurationValue(BloomFilterUtil.PREFIX_LENGTH_KEY); - } else if (bloomType == BloomType.ROWPREFIX_DELIMITED) { - bloomParam = familyDescriptor.getConfigurationValue(BloomFilterUtil.DELIMITER_KEY); } return bloomParam; }; diff --git a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java index f0e04c4d603..63c1760626f 100644 --- a/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java +++ b/hbase-mapreduce/src/test/java/org/apache/hadoop/hbase/util/LoadTestTool.java @@ -561,14 +561,6 @@ public class LoadTestTool extends AbstractHBaseTool { } } - if (bloomType == BloomType.ROWPREFIX_DELIMITED) { - if (!cmd.hasOption(OPT_BLOOM_PARAM)) { - LOG.error("the parameter of bloom filter {} is not specified", bloomType.name()); - } else { - conf.set(BloomFilterUtil.DELIMITER_KEY, cmd.getOptionValue(OPT_BLOOM_PARAM)); - } - } - inMemoryCF = cmd.hasOption(OPT_INMEMORY); if (cmd.hasOption(OPT_ENCRYPTION)) { cipher = Encryption.getCipher(conf, cmd.getOptionValue(OPT_ENCRYPTION)); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileReader.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileReader.java index d9008b2b1d9..31276784a36 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileReader.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileReader.java @@ -76,7 +76,6 @@ public class StoreFileReader { private KeyValue.KeyOnlyKeyValue lastBloomKeyOnlyKV = null; private boolean skipResetSeqId = true; private int prefixLength = -1; - private byte[] delimiter = null; // Counter that is incremented every time a scanner is created on the // store file. It is decremented when the scan on the store file is @@ -123,7 +122,6 @@ public class StoreFileReader { this.lastBloomKeyOnlyKV = reader.lastBloomKeyOnlyKV; this.skipResetSeqId = reader.skipResetSeqId; this.prefixLength = reader.prefixLength; - this.delimiter = reader.delimiter; } public boolean isPrimaryReplicaReader() { @@ -295,8 +293,6 @@ public class StoreFileReader { return true; case ROWPREFIX_FIXED_LENGTH: return passesGeneralRowPrefixBloomFilter(scan); - case ROWPREFIX_DELIMITED: - return passesGeneralDelimitedRowPrefixBloomFilter(scan); default: return true; } @@ -408,45 +404,6 @@ public class StoreFileReader { return checkGeneralBloomFilter(rowPrefix, null, bloomFilter); } - /** - * A method for checking Bloom filters. Called directly from - * StoreFileScanner in case of a multi-column query. - * - * @return True if passes - */ - private boolean passesGeneralDelimitedRowPrefixBloomFilter(Scan scan) { - BloomFilter bloomFilter = this.generalBloomFilter; - if (bloomFilter == null) { - return true; - } - - byte[] row = scan.getStartRow(); - byte[] rowPrefix; - if (scan.isGetScan()) { - int rowPrefixLength = Bytes.indexOf(row, delimiter); - if (rowPrefixLength <= 0) { - rowPrefix = row; - } else { - rowPrefix = Bytes.copy(row, 0, rowPrefixLength); - } - } else { - // For non-get scans - // If startRow does not contain delimiter, return true directly. - int startRowPrefixLength = Bytes.indexOf(row, delimiter); - if (startRowPrefixLength <= 0) { - return true; - } - // If stopRow does not have the same prefix as startRow, return true directly. - int commonLength = Bytes.findCommonPrefix(scan.getStartRow(), scan.getStopRow(), - startRowPrefixLength, scan.getStopRow().length, 0, 0); - if (commonLength < startRowPrefixLength) { - return true; - } - rowPrefix = Bytes.copy(row, 0, startRowPrefixLength); - } - return checkGeneralBloomFilter(rowPrefix, null, bloomFilter); - } - private boolean checkGeneralBloomFilter(byte[] key, Cell kvKey, BloomFilter bloomFilter) { // Empty file if (reader.getTrailer().getEntryCount() == 0) { @@ -557,8 +514,6 @@ public class StoreFileReader { byte[] p = fi.get(BLOOM_FILTER_PARAM_KEY); if (bloomFilterType == BloomType.ROWPREFIX_FIXED_LENGTH) { prefixLength = Bytes.toInt(p); - } else if (bloomFilterType == BloomType.ROWPREFIX_DELIMITED) { - delimiter = p; } lastBloomKey = fi.get(LAST_BLOOM_KEY); @@ -762,12 +717,7 @@ public class StoreFileReader { void storeFileReaderClosed(StoreFileReader reader); } - public int getPrefixLength() { return prefixLength; } - - public byte[] getDelimiter() { - return delimiter; - } } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileWriter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileWriter.java index b31df395344..837a1e2e18b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileWriter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFileWriter.java @@ -51,7 +51,6 @@ import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.RowBloomContext; import org.apache.hadoop.hbase.util.RowColBloomContext; -import org.apache.hadoop.hbase.util.RowPrefixDelimiterBloomContext; import org.apache.hadoop.hbase.util.RowPrefixFixedLengthBloomContext; import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; @@ -134,13 +133,9 @@ public class StoreFileWriter implements CellSink, ShipperListener { bloomContext = new RowPrefixFixedLengthBloomContext(generalBloomFilterWriter, comparator, Bytes.toInt(bloomParam)); break; - case ROWPREFIX_DELIMITED: - bloomContext = new RowPrefixDelimiterBloomContext(generalBloomFilterWriter, comparator, - bloomParam); - break; default: - throw new IOException("Invalid Bloom filter type: " - + bloomType + " (ROW or ROWCOL or ROWPREFIX or ROWPREFIX_DELIMITED expected)"); + throw new IOException( + "Invalid Bloom filter type: " + bloomType + " (ROW or ROWCOL or ROWPREFIX expected)"); } } else { // Not using Bloom filters. @@ -222,11 +217,10 @@ public class StoreFileWriter implements CellSink, ShipperListener { * http://2.bp.blogspot.com/_Cib_A77V54U/StZMrzaKufI/AAAAAAAAADo/ZhK7bGoJdMQ/s400/KeyValue.png * Key = RowLen + Row + FamilyLen + Column [Family + Qualifier] + Timestamp * - * 4 Types of Filtering: + * 3 Types of Filtering: * 1. Row = Row * 2. RowCol = Row + Qualifier * 3. RowPrefixFixedLength = Fixed Length Row Prefix - * 4. RowPrefixDelimiter = Delimited Row Prefix */ bloomContext.writeBloom(cell); } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/BloomFilterUtil.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/BloomFilterUtil.java index 003f38444c3..b932c4d9237 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/BloomFilterUtil.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/BloomFilterUtil.java @@ -17,6 +17,8 @@ */ package org.apache.hadoop.hbase.util; +import static org.apache.hadoop.hbase.regionserver.BloomType.ROWPREFIX_FIXED_LENGTH; + import java.text.NumberFormat; import java.util.Random; @@ -50,7 +52,6 @@ public final class BloomFilterUtil { private static Random randomGeneratorForTest; public static final String PREFIX_LENGTH_KEY = "RowPrefixBloomFilter.prefix_length"; - public static final String DELIMITER_KEY = "RowPrefixDelimitedBloomFilter.delimiter"; /** Bit-value lookup array to prevent doing the same work over and over */ public static final byte [] bitvals = { @@ -291,42 +292,29 @@ public final class BloomFilterUtil { } public static byte[] getBloomFilterParam(BloomType bloomFilterType, Configuration conf) - throws IllegalArgumentException{ + throws IllegalArgumentException { byte[] bloomParam = null; String message = "Bloom filter type is " + bloomFilterType + ", "; - switch (bloomFilterType) { - case ROWPREFIX_FIXED_LENGTH: - String prefixLengthString = conf.get(PREFIX_LENGTH_KEY); - if (prefixLengthString == null) { - message += PREFIX_LENGTH_KEY + " not specified."; + if (bloomFilterType.equals(ROWPREFIX_FIXED_LENGTH)) { + String prefixLengthString = conf.get(PREFIX_LENGTH_KEY); + if (prefixLengthString == null) { + message += PREFIX_LENGTH_KEY + " not specified."; + throw new IllegalArgumentException(message); + } + int prefixLength; + try { + prefixLength = Integer.parseInt(prefixLengthString); + if (prefixLength <= 0 || prefixLength > HConstants.MAX_ROW_LENGTH) { + message += + "the value of " + PREFIX_LENGTH_KEY + " must >=0 and < " + HConstants.MAX_ROW_LENGTH; throw new IllegalArgumentException(message); } - int prefixLength; - try { - prefixLength = Integer.parseInt(prefixLengthString); - if (prefixLength <= 0 || prefixLength > HConstants.MAX_ROW_LENGTH) { - message += "the value of " + PREFIX_LENGTH_KEY - + " must >=0 and < " + HConstants.MAX_ROW_LENGTH; - throw new IllegalArgumentException(message); - } - } catch (NumberFormatException nfe) { - message = "Number format exception when parsing " + PREFIX_LENGTH_KEY + " for BloomType " - + bloomFilterType.toString() + ":" - + prefixLengthString; - throw new IllegalArgumentException(message, nfe); - } - bloomParam = Bytes.toBytes(prefixLength); - break; - case ROWPREFIX_DELIMITED: - String delimiterString = conf.get(DELIMITER_KEY); - if (delimiterString == null || delimiterString.length() == 0) { - message += DELIMITER_KEY + " not specified."; - throw new IllegalArgumentException(message); - } - bloomParam = Bytes.toBytes(delimiterString); - break; - default: - break; + } catch (NumberFormatException nfe) { + message = "Number format exception when parsing " + PREFIX_LENGTH_KEY + " for BloomType " + + bloomFilterType.toString() + ":" + prefixLengthString; + throw new IllegalArgumentException(message, nfe); + } + bloomParam = Bytes.toBytes(prefixLength); } return bloomParam; } diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RowPrefixDelimiterBloomContext.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RowPrefixDelimiterBloomContext.java deleted file mode 100644 index 5fcf43b114e..00000000000 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RowPrefixDelimiterBloomContext.java +++ /dev/null @@ -1,62 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.hadoop.hbase.util; - -import java.io.IOException; - -import org.apache.hadoop.hbase.Cell; -import org.apache.hadoop.hbase.CellBuilderType; -import org.apache.hadoop.hbase.CellComparator; -import org.apache.hadoop.hbase.CellUtil; -import org.apache.hadoop.hbase.ExtendedCellBuilderFactory; -import org.apache.yetus.audience.InterfaceAudience; - -/** - * Handles ROWPREFIX_DELIMITED bloom related context. - * It works with both ByteBufferedCell and byte[] backed cells - */ -@InterfaceAudience.Private -public class RowPrefixDelimiterBloomContext extends RowBloomContext { - private final byte[] delimiter; - - public RowPrefixDelimiterBloomContext(BloomFilterWriter bloomFilterWriter, - CellComparator comparator, byte[] delimiter) { - super(bloomFilterWriter, comparator); - this.delimiter = delimiter; - } - - public void writeBloom(Cell cell) throws IOException { - super.writeBloom(getDelimitedRowPrefixCell(cell)); - } - - /** - * @param cell the new cell - * @return the new cell created by delimited row prefix - */ - private Cell getDelimitedRowPrefixCell(Cell cell) { - byte[] row = CellUtil.copyRow(cell); - int prefixLength = Bytes.indexOf(row, delimiter); - if (prefixLength <= 0) { - return cell; - } - return ExtendedCellBuilderFactory.create(CellBuilderType.DEEP_COPY) - .setRow(row, 0, Math.min(prefixLength, row.length)) - .setType(Cell.Type.Put) - .build(); - } -} diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestSeekBeforeWithInlineBlocks.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestSeekBeforeWithInlineBlocks.java index cadcad6e1ff..645134434b9 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestSeekBeforeWithInlineBlocks.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/io/hfile/TestSeekBeforeWithInlineBlocks.java @@ -82,7 +82,6 @@ public class TestSeekBeforeWithInlineBlocks { public void testMultiIndexLevelRandomHFileWithBlooms() throws IOException { conf = TEST_UTIL.getConfiguration(); TEST_UTIL.getConfiguration().setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, 10); - TEST_UTIL.getConfiguration().set(BloomFilterUtil.DELIMITER_KEY, "#"); // Try out different HFile versions to ensure reverse scan works on each version for (int hfileVersion = HFile.MIN_FORMAT_VERSION_WITH_TAGS; @@ -105,7 +104,6 @@ public class TestSeekBeforeWithInlineBlocks { conf.setInt(HFileBlockIndex.MAX_CHUNK_SIZE_KEY, indexBlockSize); conf.setInt(BloomFilterFactory.IO_STOREFILE_BLOOM_BLOCK_SIZE, BLOOM_BLOCK_SIZE); conf.setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, 10); - conf.set(BloomFilterUtil.DELIMITER_KEY, "#"); Cell[] cells = new Cell[NUM_KV]; diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/CreateRandomStoreFile.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/CreateRandomStoreFile.java index 8a512e62dfc..67caf8ea209 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/CreateRandomStoreFile.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/CreateRandomStoreFile.java @@ -183,15 +183,6 @@ public class CreateRandomStoreFile { } } - if (bloomType == BloomType.ROWPREFIX_DELIMITED) { - if (!cmdLine.hasOption(BLOOM_FILTER_PARAM_OPTION)) { - LOG.error("the parameter of bloom filter is not specified"); - return false; - } else { - conf.set(BloomFilterUtil.DELIMITER_KEY, cmdLine.getOptionValue(BLOOM_FILTER_PARAM_OPTION)); - } - } - int blockSize = HConstants.DEFAULT_BLOCKSIZE; if (cmdLine.hasOption(BLOCK_SIZE_OPTION)) blockSize = Integer.valueOf(cmdLine.getOptionValue(BLOCK_SIZE_OPTION)); diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java index ab591ad93b3..5950b943584 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestMultiColumnScanner.java @@ -138,7 +138,6 @@ public abstract class TestMultiColumnScanner { @Test public void testMultiColumnScanner() throws IOException { TEST_UTIL.getConfiguration().setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, 10); - TEST_UTIL.getConfiguration().set(BloomFilterUtil.DELIMITER_KEY, "#"); HRegion region = TEST_UTIL.createTestRegion(TABLE_NAME, ColumnFamilyDescriptorBuilder.newBuilder(FAMILY_BYTES).setCompressionType(comprAlgo) .setBloomFilterType(bloomType).setMaxVersions(MAX_VERSIONS) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRowPrefixBloomFilter.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRowPrefixBloomFilter.java index 647f450e3d2..0fd5d231ae4 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRowPrefixBloomFilter.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestRowPrefixBloomFilter.java @@ -78,10 +78,13 @@ public class TestRowPrefixBloomFilter { private static final int BLOCKSIZE_SMALL = 8192; private static final float err = (float) 0.01; private static final int prefixLength = 10; - private static final String delimiter = "#"; private static final String invalidFormatter = "%08d"; private static final String prefixFormatter = "%010d"; private static final String suffixFormatter = "%010d"; + private static final int prefixRowCount = 50; + private static final int suffixRowCount = 10; + private static final int fixedLengthExpKeys = prefixRowCount; + private static final BloomType bt = BloomType.ROWPREFIX_FIXED_LENGTH; @Rule public TestName name = new TestName(); @@ -92,7 +95,6 @@ public class TestRowPrefixBloomFilter { conf.setFloat(BloomFilterFactory.IO_STOREFILE_BLOOM_ERROR_RATE, err); conf.setBoolean(BloomFilterFactory.IO_STOREFILE_BLOOM_ENABLED, true); conf.setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, prefixLength); - conf.set(BloomFilterUtil.DELIMITER_KEY, delimiter); localfs = (conf.get("fs.defaultFS", "file:///").compareTo("file:///") == 0); @@ -132,8 +134,7 @@ public class TestRowPrefixBloomFilter { return reader.getStoreFileScanner(false, false, false, 0, 0, false); } - private void writeStoreFile(final Path f, BloomType bt, int expKeys, int prefixRowCount, - int suffixRowCount) throws IOException { + private void writeStoreFile(final Path f, BloomType bt, int expKeys) throws IOException { HFileContext meta = new HFileContextBuilder() .withBlockSize(BLOCKSIZE_SMALL) .withChecksumType(CKTYPE) @@ -152,18 +153,20 @@ public class TestRowPrefixBloomFilter { for (int i = 0; i < prefixRowCount; i += 2) { // prefix rows String prefixRow = String.format(prefixFormatter, i); for (int j = 0; j < suffixRowCount; j++) { // suffix rows - String row = prefixRow + "#" + String.format(suffixFormatter, j); - KeyValue kv = new KeyValue(Bytes.toBytes(row), Bytes.toBytes("family"), - Bytes.toBytes("col"), now, Bytes.toBytes("value")); + String row = generateRowWithSuffix(prefixRow, j); + KeyValue kv = + new KeyValue(Bytes.toBytes(row), Bytes.toBytes("family"), Bytes.toBytes("col"), now, + Bytes.toBytes("value")); writer.append(kv); } } //Put with invalid row style - for (int i = prefixRowCount; i < prefixRowCount*2; i += 2) { // prefix rows + for (int i = prefixRowCount; i < prefixRowCount * 2; i += 2) { // prefix rows String row = String.format(invalidFormatter, i); - KeyValue kv = new KeyValue(Bytes.toBytes(row), Bytes.toBytes("family"), - Bytes.toBytes("col"), now, Bytes.toBytes("value")); + KeyValue kv = + new KeyValue(Bytes.toBytes(row), Bytes.toBytes("family"), Bytes.toBytes("col"), now, + Bytes.toBytes("value")); writer.append(kv); } } finally { @@ -171,66 +174,45 @@ public class TestRowPrefixBloomFilter { } } + private String generateRowWithSuffix(String prefixRow, int suffix) { + StringBuilder row = new StringBuilder(prefixRow); + row.append("#"); + row.append(String.format(suffixFormatter, suffix)); + return row.toString(); + } + @Test public void testRowPrefixBloomFilter() throws Exception { FileSystem fs = FileSystem.getLocal(conf); - BloomType[] bt = {BloomType.ROWPREFIX_FIXED_LENGTH, BloomType.ROWPREFIX_DELIMITED}; - int prefixRowCount = 50; - int suffixRowCount = 10; - int expKeys = 50; - float expErr = 2*prefixRowCount*suffixRowCount*err; - for (int x : new int[]{0,1}) { - // write the file - Path f = new Path(testDir, name.getMethodName()); - writeStoreFile(f, bt[x], expKeys, prefixRowCount, suffixRowCount); + float expErr = 2 * prefixRowCount * suffixRowCount * err; + int expKeys = fixedLengthExpKeys; + // write the file + Path f = new Path(testDir, name.getMethodName()); + writeStoreFile(f, bt, expKeys); - // read the file - StoreFileReader reader = new StoreFileReader(fs, f, cacheConf, true, - new AtomicInteger(0), true, conf); - reader.loadFileInfo(); - reader.loadBloomfilter(); + // read the file + StoreFileReader reader = + new StoreFileReader(fs, f, cacheConf, true, new AtomicInteger(0), true, conf); + reader.loadFileInfo(); + reader.loadBloomfilter(); - //check basic param - assertEquals(bt[x], reader.getBloomFilterType()); - if (bt[x] == BloomType.ROWPREFIX_FIXED_LENGTH) { - assertEquals(prefixLength, reader.getPrefixLength()); - assertEquals("null", Bytes.toStringBinary(reader.getDelimiter())); - } else if (bt[x] == BloomType.ROWPREFIX_DELIMITED){ - assertEquals(-1, reader.getPrefixLength()); - assertEquals(delimiter, Bytes.toStringBinary(reader.getDelimiter())); - } - assertEquals(expKeys, reader.getGeneralBloomFilter().getKeyCount()); - StoreFileScanner scanner = getStoreFileScanner(reader); - HStore store = mock(HStore.class); - when(store.getColumnFamilyDescriptor()) - .thenReturn(ColumnFamilyDescriptorBuilder.of("family")); - // check false positives rate - int falsePos = 0; - int falseNeg = 0; - for (int i = 0; i < prefixRowCount; i++) { // prefix rows - String prefixRow = String.format(prefixFormatter, i); - for (int j = 0; j < suffixRowCount; j++) { // suffix rows - String startRow = prefixRow + "#" + String.format(suffixFormatter, j); - String stopRow = prefixRow + "#" + String.format(suffixFormatter, j+1); - Scan scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - boolean shouldPrefixRowExist = i % 2 == 0; - if (shouldPrefixRowExist) { - if (!exists) { - falseNeg++; - } - } else { - if (exists) { - falsePos++; - } - } - } - } - - for (int i = prefixRowCount; i < prefixRowCount * 2; i++) { // prefix rows - String row = String.format(invalidFormatter, i); - Scan scan = new Scan(new Get(Bytes.toBytes(row))); + //check basic param + assertEquals(bt, reader.getBloomFilterType()); + assertEquals(prefixLength, reader.getPrefixLength()); + assertEquals(expKeys, reader.getGeneralBloomFilter().getKeyCount()); + StoreFileScanner scanner = getStoreFileScanner(reader); + HStore store = mock(HStore.class); + when(store.getColumnFamilyDescriptor()).thenReturn(ColumnFamilyDescriptorBuilder.of("family")); + // check false positives rate + int falsePos = 0; + int falseNeg = 0; + for (int i = 0; i < prefixRowCount; i++) { // prefix rows + String prefixRow = String.format(prefixFormatter, i); + for (int j = 0; j < suffixRowCount; j++) { // suffix rows + String startRow = generateRowWithSuffix(prefixRow, j); + String stopRow = generateRowWithSuffix(prefixRow, j + 1); + Scan scan = + new Scan().withStartRow(Bytes.toBytes(startRow)).withStopRow(Bytes.toBytes(stopRow)); boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); boolean shouldPrefixRowExist = i % 2 == 0; if (shouldPrefixRowExist) { @@ -243,157 +225,136 @@ public class TestRowPrefixBloomFilter { } } } - reader.close(true); // evict because we are about to delete the file - fs.delete(f, true); - assertEquals("False negatives: " + falseNeg, 0, falseNeg); - int maxFalsePos = (int) (2 * expErr); - assertTrue("Too many false positives: " + falsePos - + " (err=" + err + ", expected no more than " + maxFalsePos + ")", - falsePos <= maxFalsePos); } + + for (int i = prefixRowCount; i < prefixRowCount * 2; i++) { // prefix rows + String row = String.format(invalidFormatter, i); + Scan scan = new Scan(new Get(Bytes.toBytes(row))); + boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + boolean shouldPrefixRowExist = i % 2 == 0; + if (shouldPrefixRowExist) { + if (!exists) { + falseNeg++; + } + } else { + if (exists) { + falsePos++; + } + } + } + reader.close(true); // evict because we are about to delete the file + fs.delete(f, true); + assertEquals("False negatives: " + falseNeg, 0, falseNeg); + int maxFalsePos = (int) (2 * expErr); + assertTrue( + "Too many false positives: " + falsePos + " (err=" + err + ", expected no more than " + + maxFalsePos + ")", falsePos <= maxFalsePos); } @Test public void testRowPrefixBloomFilterWithGet() throws Exception { FileSystem fs = FileSystem.getLocal(conf); - BloomType[] bt = {BloomType.ROWPREFIX_FIXED_LENGTH, BloomType.ROWPREFIX_DELIMITED}; - int prefixRowCount = 50; - int suffixRowCount = 10; - int expKeys = 50; - for (int x : new int[]{0,1}) { - // write the file - Path f = new Path(testDir, name.getMethodName()); - writeStoreFile(f, bt[x], expKeys, prefixRowCount, suffixRowCount); + int expKeys = fixedLengthExpKeys; + // write the file + Path f = new Path(testDir, name.getMethodName()); + writeStoreFile(f, bt, expKeys); - StoreFileReader reader = new StoreFileReader(fs, f, cacheConf, true, - new AtomicInteger(0), true, conf); - reader.loadFileInfo(); - reader.loadBloomfilter(); + StoreFileReader reader = + new StoreFileReader(fs, f, cacheConf, true, new AtomicInteger(0), true, conf); + reader.loadFileInfo(); + reader.loadBloomfilter(); - StoreFileScanner scanner = getStoreFileScanner(reader); - HStore store = mock(HStore.class); - when(store.getColumnFamilyDescriptor()) - .thenReturn(ColumnFamilyDescriptorBuilder.of("family")); + StoreFileScanner scanner = getStoreFileScanner(reader); + HStore store = mock(HStore.class); + when(store.getColumnFamilyDescriptor()).thenReturn(ColumnFamilyDescriptorBuilder.of("family")); - //Get with valid row style - //prefix row in bloom - String prefixRow = String.format(prefixFormatter, prefixRowCount-2); - String row = prefixRow + "#" + String.format(suffixFormatter, 0); - Scan scan = new Scan(new Get(Bytes.toBytes(row))); - boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); + //Get with valid row style + //prefix row in bloom + String prefixRow = String.format(prefixFormatter, prefixRowCount - 2); + String row = generateRowWithSuffix(prefixRow, 0); + Scan scan = new Scan(new Get(Bytes.toBytes(row))); + boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertTrue(exists); - // prefix row not in bloom - prefixRow = String.format(prefixFormatter, prefixRowCount-1); - row = prefixRow + "#" + String.format(suffixFormatter, 0); - scan = new Scan(new Get(Bytes.toBytes(row))); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertFalse(exists); + // prefix row not in bloom + prefixRow = String.format(prefixFormatter, prefixRowCount - 1); + row = generateRowWithSuffix(prefixRow, 0); + scan = new Scan(new Get(Bytes.toBytes(row))); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertFalse(exists); - // Get with invalid row style - // ROWPREFIX: the length of row is less than prefixLength - // ROWPREFIX_DELIMITED: Row does not contain delimiter - // row in bloom - row = String.format(invalidFormatter, prefixRowCount+2); - scan = new Scan(new Get(Bytes.toBytes(row))); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); + // Get with invalid row style + // ROWPREFIX: the length of row is less than prefixLength + // row in bloom + row = String.format(invalidFormatter, prefixRowCount + 2); + scan = new Scan(new Get(Bytes.toBytes(row))); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertTrue(exists); - // row not in bloom - row = String.format(invalidFormatter, prefixRowCount+1); - scan = new Scan(new Get(Bytes.toBytes(row))); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertFalse(exists); + // row not in bloom + row = String.format(invalidFormatter, prefixRowCount + 1); + scan = new Scan(new Get(Bytes.toBytes(row))); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertFalse(exists); - reader.close(true); // evict because we are about to delete the file - fs.delete(f, true); - } + reader.close(true); // evict because we are about to delete the file + fs.delete(f, true); } @Test public void testRowPrefixBloomFilterWithScan() throws Exception { FileSystem fs = FileSystem.getLocal(conf); - BloomType[] bt = {BloomType.ROWPREFIX_FIXED_LENGTH, BloomType.ROWPREFIX_DELIMITED}; - int prefixRowCount = 50; - int suffixRowCount = 10; - int expKeys = 50; - for (int x : new int[]{0,1}) { - // write the file - Path f = new Path(testDir, name.getMethodName()); - writeStoreFile(f, bt[x], expKeys, prefixRowCount, suffixRowCount); + int expKeys = fixedLengthExpKeys; + // write the file + Path f = new Path(testDir, name.getMethodName()); + writeStoreFile(f, bt, expKeys); - StoreFileReader reader = new StoreFileReader(fs, f, cacheConf, true, - new AtomicInteger(0), true, conf); - reader.loadFileInfo(); - reader.loadBloomfilter(); + StoreFileReader reader = + new StoreFileReader(fs, f, cacheConf, true, new AtomicInteger(0), true, conf); + reader.loadFileInfo(); + reader.loadBloomfilter(); - StoreFileScanner scanner = getStoreFileScanner(reader); - HStore store = mock(HStore.class); - when(store.getColumnFamilyDescriptor()) - .thenReturn(ColumnFamilyDescriptorBuilder.of("family")); + StoreFileScanner scanner = getStoreFileScanner(reader); + HStore store = mock(HStore.class); + when(store.getColumnFamilyDescriptor()).thenReturn(ColumnFamilyDescriptorBuilder.of("family")); - //Scan with valid row style. startRow and stopRow have a common prefix. - //And the length of the common prefix is no less than prefixLength. - //prefix row in bloom - String prefixRow = String.format(prefixFormatter, prefixRowCount-2); - String startRow = prefixRow + "#" + String.format(suffixFormatter, 0); - String stopRow = prefixRow + "#" + String.format(suffixFormatter, 1); - Scan scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); + //Scan with valid row style. startRow and stopRow have a common prefix. + //And the length of the common prefix is no less than prefixLength. + //prefix row in bloom + String prefixRow = String.format(prefixFormatter, prefixRowCount - 2); + String startRow = generateRowWithSuffix(prefixRow, 0); + String stopRow = generateRowWithSuffix(prefixRow, 1); + Scan scan = + new Scan().withStartRow(Bytes.toBytes(startRow)).withStopRow(Bytes.toBytes(stopRow)); + boolean exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertTrue(exists); - // prefix row not in bloom - prefixRow = String.format(prefixFormatter, prefixRowCount-1); - startRow = prefixRow + "#" + String.format(suffixFormatter, 0); - stopRow = prefixRow + "#" + String.format(suffixFormatter, 1); - scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertFalse(exists); + // prefix row not in bloom + prefixRow = String.format(prefixFormatter, prefixRowCount - 1); + startRow = generateRowWithSuffix(prefixRow, 0); + stopRow = generateRowWithSuffix(prefixRow, 1); + scan = new Scan().withStartRow(Bytes.toBytes(startRow)).withStopRow(Bytes.toBytes(stopRow)); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertFalse(exists); - // There is no common prefix between startRow and stopRow. - prefixRow = String.format(prefixFormatter, prefixRowCount-2); - startRow = prefixRow + "#" + String.format(suffixFormatter, 0); - scan = new Scan().withStartRow(Bytes.toBytes(startRow)); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); + // There is no common prefix between startRow and stopRow. + prefixRow = String.format(prefixFormatter, prefixRowCount - 2); + startRow = generateRowWithSuffix(prefixRow, 0); + scan = new Scan().withStartRow(Bytes.toBytes(startRow)); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertTrue(exists); - if (bt[x] == BloomType.ROWPREFIX_FIXED_LENGTH) { - // startRow and stopRow have a common prefix. - // But the length of the common prefix is less than prefixLength. - String prefixStartRow = String.format(prefixFormatter, prefixRowCount-2); - String prefixStopRow = String.format(prefixFormatter, prefixRowCount-1); - startRow = prefixStartRow + "#" + String.format(suffixFormatter, 0); - stopRow = prefixStopRow + "#" + String.format(suffixFormatter, 0); - scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); - }else if (bt[x] == BloomType.ROWPREFIX_DELIMITED) { - // startRow does not contain delimiter - String prefixStartRow = String.format(prefixFormatter, prefixRowCount-2); - String prefixStopRow = String.format(prefixFormatter, prefixRowCount-2); - startRow = prefixStartRow + String.format(suffixFormatter, 0); - stopRow = prefixStopRow + "#" + String.format(suffixFormatter, 0); - scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); + // startRow and stopRow have a common prefix. + // But the length of the common prefix is less than prefixLength. + String prefixStartRow = String.format(prefixFormatter, prefixRowCount - 2); + String prefixStopRow = String.format(prefixFormatter, prefixRowCount - 1); + startRow = generateRowWithSuffix(prefixStartRow, 0); + stopRow = generateRowWithSuffix(prefixStopRow, 0); + scan = new Scan().withStartRow(Bytes.toBytes(startRow)).withStopRow(Bytes.toBytes(stopRow)); + exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); + assertTrue(exists); - // startRow contains delimiter, but stopRow does not have the same prefix as startRow. - prefixStartRow = String.format(prefixFormatter, prefixRowCount-2); - prefixStopRow = String.format(prefixFormatter, prefixRowCount-1); - startRow = prefixStartRow + "#" + String.format(suffixFormatter, 0); - stopRow = prefixStopRow + "#" + String.format(suffixFormatter, 0); - scan = new Scan().withStartRow(Bytes.toBytes(startRow)) - .withStopRow(Bytes.toBytes(stopRow)); - exists = scanner.shouldUseScanner(scan, store, Long.MIN_VALUE); - assertTrue(exists); - } - - reader.close(true); // evict because we are about to delete the file - fs.delete(f, true); - } + reader.close(true); // evict because we are about to delete the file + fs.delete(f, true); } } diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java index 4c58c011ed0..3cf7447352f 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestScanWithBloomError.java @@ -105,7 +105,6 @@ public class TestScanWithBloomError { conf = TEST_UTIL.getConfiguration(); fs = FileSystem.get(conf); conf.setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, 10); - conf.set(BloomFilterUtil.DELIMITER_KEY, "#"); } @Test diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java index 1e04e8de8f4..f6db8fa5384 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestSeekOptimizations.java @@ -144,7 +144,6 @@ public class TestSeekOptimizations { rand = new Random(91238123L); expectedKVs.clear(); TEST_UTIL.getConfiguration().setInt(BloomFilterUtil.PREFIX_LENGTH_KEY, 10); - TEST_UTIL.getConfiguration().set(BloomFilterUtil.DELIMITER_KEY, "#"); } @Test @@ -485,6 +484,5 @@ public class TestSeekOptimizations { HBaseTestingUtility.safeGetAsStr(actual, i) + " (length " + aLen + ")" + additionalMsg); } } - } diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java index d13aaf2b5f9..128ba6a3323 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/AlreadyExists.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated; * An AlreadyExists exceptions signals that a table with the specified * name already exists */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class AlreadyExists extends org.apache.thrift.TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("AlreadyExists"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java index 5b21f95f10e..838e205f883 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/BatchMutation.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * A BatchMutation object is used to apply a number of Mutations to a single row. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class BatchMutation implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("BatchMutation"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/ColumnDescriptor.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/ColumnDescriptor.java index d548c22f4b6..ba24da71c2a 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/ColumnDescriptor.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/ColumnDescriptor.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift.generated; * such as the number of versions, compression settings, etc. It is * used as input when creating a table or adding a column. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class ColumnDescriptor implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("ColumnDescriptor"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java index 19900970afe..20605a91bf5 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Hbase.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class Hbase { public interface Iface { diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java index 5a3bb38e992..c20d90ce7a5 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IOError.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift.generated; * to the Hbase master or an Hbase region server. Also used to return * more general Hbase error conditions. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class IOError extends org.apache.thrift.TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("IOError"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IllegalArgument.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IllegalArgument.java index a3043d75383..160c1863c44 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IllegalArgument.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/IllegalArgument.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated; * An IllegalArgument exception indicates an illegal or invalid * argument was passed into a procedure. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class IllegalArgument extends org.apache.thrift.TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("IllegalArgument"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java index 2bf11e69d81..fc7016a8b86 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/Mutation.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * A Mutation object is used to either update or delete a column-value. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class Mutation implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Mutation"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TAppend.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TAppend.java index dd276b49646..13dbe4727d8 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TAppend.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TAppend.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * An Append object is used to specify the parameters for performing the append operation. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TAppend implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAppend"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TCell.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TCell.java index 1ddfa7bb411..80d479a3db6 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TCell.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TCell.java @@ -13,7 +13,7 @@ package org.apache.hadoop.hbase.thrift.generated; * the timestamp of a cell to a first-class value, making it easy to take * note of temporal data. Cell is used all the way from HStore up to HTable. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TCell implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TCell"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TColumn.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TColumn.java index 526b23604ee..5f9984c07a7 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TColumn.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TColumn.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * Holds column name and the cell. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TColumn implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumn"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TIncrement.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TIncrement.java index a48f9b4eb1c..0dddf923fa4 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TIncrement.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TIncrement.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift.generated; * For increments that are not incrementColumnValue * equivalents. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TIncrement implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIncrement"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java index e095277fdd4..e283eb79b49 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRegionInfo.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * A TRegionInfo contains information about an HTable region. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TRegionInfo implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRegionInfo"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java index 9524f741b2b..eaaa3bb98d1 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TRowResult.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * Holds row name and then a map of columns to cells. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TRowResult implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRowResult"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TScan.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TScan.java index 5f97a606e12..0582bf296f3 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TScan.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift/generated/TScan.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift.generated; /** * A Scan object is used to specify scanner parameters when opening a scanner. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TScan implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TScan"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftUtilities.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftUtilities.java index 3496726b8da..0ffedf6d64e 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftUtilities.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/ThriftUtilities.java @@ -885,7 +885,6 @@ public final class ThriftUtilities { case 1: return BloomType.ROW; case 2: return BloomType.ROWCOL; case 3: return BloomType.ROWPREFIX_FIXED_LENGTH; - case 4: return BloomType.ROWPREFIX_DELIMITED; default: return BloomType.ROW; } } @@ -1110,7 +1109,6 @@ public final class ThriftUtilities { case ROW: return TBloomFilterType.ROW; case ROWCOL: return TBloomFilterType.ROWCOL; case ROWPREFIX_FIXED_LENGTH: return TBloomFilterType.ROWPREFIX_FIXED_LENGTH; - case ROWPREFIX_DELIMITED: return TBloomFilterType.ROWPREFIX_DELIMITED; default: return TBloomFilterType.ROW; } } diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAppend.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAppend.java index 7c4f77a402d..9253b72de32 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAppend.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAppend.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TAppend implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAppend"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAuthorization.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAuthorization.java index c16e12f5e5a..5cdb341cad4 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAuthorization.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TAuthorization.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TAuthorization implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TAuthorization"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TBloomFilterType.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TBloomFilterType.java index c06c8ecbf2b..f881c22363f 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TBloomFilterType.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TBloomFilterType.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.regionserver.BloomType */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TBloomFilterType implements org.apache.thrift.TEnum { /** * Bloomfilters disabled @@ -28,11 +28,7 @@ public enum TBloomFilterType implements org.apache.thrift.TEnum { /** * Bloom enabled with Table row prefix as Key, specify the length of the prefix */ - ROWPREFIX_FIXED_LENGTH(3), - /** - * Bloom enabled with Table row prefix as Key, specify the delimiter of the prefix - */ - ROWPREFIX_DELIMITED(4); + ROWPREFIX_FIXED_LENGTH(3); private final int value; @@ -62,8 +58,6 @@ public enum TBloomFilterType implements org.apache.thrift.TEnum { return ROWCOL; case 3: return ROWPREFIX_FIXED_LENGTH; - case 4: - return ROWPREFIX_DELIMITED; default: return null; } diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCellVisibility.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCellVisibility.java index 802b79c4d85..f4199508e14 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCellVisibility.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCellVisibility.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TCellVisibility implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TCellVisibility"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java index 4de5a0ee13f..cee1dde60cc 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumn.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * in a HBase table by column family and optionally * a column qualifier and timestamp */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TColumn implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumn"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnFamilyDescriptor.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnFamilyDescriptor.java index efab7d77aea..24c87c5b198 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnFamilyDescriptor.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnFamilyDescriptor.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.client.ColumnFamilyDescriptor */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TColumnFamilyDescriptor implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnFamilyDescriptor"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java index d215066caf1..af9734cc6a1 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnIncrement.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated; /** * Represents a single cell and the amount to increment it by */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TColumnIncrement implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnIncrement"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java index 0cbdcd858f8..25bdbe833e3 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TColumnValue.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated; /** * Represents a single cell and its value. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TColumnValue implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TColumnValue"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompareOp.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompareOp.java index e9c0cc74015..dcdf24b1980 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompareOp.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompareOp.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.filter.CompareFilter$CompareOp. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TCompareOp implements org.apache.thrift.TEnum { LESS(0), LESS_OR_EQUAL(1), diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompressionAlgorithm.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompressionAlgorithm.java index ce689638f0d..acc484f9f5c 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompressionAlgorithm.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TCompressionAlgorithm.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.io.compress.Algorithm */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TCompressionAlgorithm implements org.apache.thrift.TEnum { LZO(0), GZ(1), diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TConsistency.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TConsistency.java index 5e5b66c8348..916e8074f67 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TConsistency.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TConsistency.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * - STRONG means reads only from primary region * - TIMELINE means reads might return values from secondary region replicas */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TConsistency implements org.apache.thrift.TEnum { STRONG(1), TIMELINE(2); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDataBlockEncoding.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDataBlockEncoding.java index 29fa6fbebfb..a1364216d57 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDataBlockEncoding.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDataBlockEncoding.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.io.encoding.DataBlockEncoding */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TDataBlockEncoding implements org.apache.thrift.TEnum { /** * Disable data block encoding. diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java index 30118b9edc3..5026ea528e0 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDelete.java @@ -33,7 +33,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * by changing the durability. If you don't provide durability, it defaults to * column family's default setting for durability. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TDelete implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TDelete"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java index f400414bf44..f5977d01008 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDeleteType.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * - DELETE_COLUMN means exactly one version will be removed, * - DELETE_COLUMNS means previous versions will also be removed. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TDeleteType implements org.apache.thrift.TEnum { DELETE_COLUMN(0), DELETE_COLUMNS(1), diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDurability.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDurability.java index 06c856bbafd..9322e5fa1b2 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDurability.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TDurability.java @@ -14,7 +14,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * - SYNC_WAL means write the Mutation to the WAL synchronously, * - FSYNC_WAL means Write the Mutation to the WAL synchronously and force the entries to disk. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TDurability implements org.apache.thrift.TEnum { USE_DEFAULT(0), SKIP_WAL(1), diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java index dc51ca9ee20..b0744ea4c83 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TGet.java @@ -20,7 +20,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * If you specify a time range and a timestamp the range is ignored. * Timestamps on TColumns are ignored. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TGet implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TGet"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java index 69ce4a67ff1..8ebacfd3502 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THBaseService.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class THBaseService { public interface Iface { diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionInfo.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionInfo.java index 39ea075eb7f..7fe327ebfbb 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionInfo.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionInfo.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class THRegionInfo implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("THRegionInfo"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionLocation.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionLocation.java index 0b155555de4..bd154bd94e5 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionLocation.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/THRegionLocation.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class THRegionLocation implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("THRegionLocation"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java index c952a61744e..e527c18ab0e 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIOError.java @@ -12,7 +12,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * to the HBase master or a HBase region server. Also used to return * more general HBase error conditions. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TIOError extends org.apache.thrift.TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIOError"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java index 3e9f3a851fc..cee533de87c 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIllegalArgument.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * A TIllegalArgument exception indicates an illegal or invalid * argument was passed into a procedure. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TIllegalArgument extends org.apache.thrift.TException implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIllegalArgument"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java index c00008f075d..386fc4a0311 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TIncrement.java @@ -14,7 +14,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * by changing the durability. If you don't provide durability, it defaults to * column family's default setting for durability. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TIncrement implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TIncrement"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TKeepDeletedCells.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TKeepDeletedCells.java index 3e48f1b1cc0..1387d751c26 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TKeepDeletedCells.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TKeepDeletedCells.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.KeepDeletedCells */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TKeepDeletedCells implements org.apache.thrift.TEnum { /** * Deleted Cells are not retained. diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TMutation.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TMutation.java index cc92c9de52b..79804adfe37 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TMutation.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TMutation.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated; /** * Atomic mutation for the specified row. It can be either Put or Delete. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TMutation extends org.apache.thrift.TUnion { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TMutation"); private static final org.apache.thrift.protocol.TField PUT_FIELD_DESC = new org.apache.thrift.protocol.TField("put", org.apache.thrift.protocol.TType.STRUCT, (short)1); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TNamespaceDescriptor.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TNamespaceDescriptor.java index 67af857a221..5d4cc5582aa 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TNamespaceDescriptor.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TNamespaceDescriptor.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.NamespaceDescriptor */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TNamespaceDescriptor implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TNamespaceDescriptor"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java index a9a38294ede..6c49fb57abe 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TPut.java @@ -19,7 +19,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * by changing the durability. If you don't provide durability, it defaults to * column family's default setting for durability. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TPut implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TPut"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TReadType.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TReadType.java index 7ab12d5a2d2..10d244add25 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TReadType.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TReadType.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public enum TReadType implements org.apache.thrift.TEnum { DEFAULT(1), STREAM(2), diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java index 687a9bec9f2..dd2f27c7317 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TResult.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated; /** * if no Result is found, row and columnValues will not be set. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TResult implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TResult"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TRowMutations.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TRowMutations.java index 9a178cddb93..1e616cd5004 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TRowMutations.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TRowMutations.java @@ -10,7 +10,7 @@ package org.apache.hadoop.hbase.thrift2.generated; /** * A TRowMutations object is used to apply a number of Mutations to a single row. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TRowMutations implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TRowMutations"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java index d660656eafc..6626dce7e81 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TScan.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Any timestamps in the columns are ignored but the colFamTimeRangeMap included, use timeRange to select by timestamp. * Max versions defaults to 1. */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TScan implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TScan"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TServerName.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TServerName.java index 5a7d1425d40..edffca1e67f 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TServerName.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TServerName.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TServerName implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TServerName"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableDescriptor.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableDescriptor.java index 4ea2374c653..fc24d13ae4e 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableDescriptor.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableDescriptor.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.client.TableDescriptor */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TTableDescriptor implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableDescriptor"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableName.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableName.java index de550d7d7c4..5f821db8085 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableName.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTableName.java @@ -11,7 +11,7 @@ package org.apache.hadoop.hbase.thrift2.generated; * Thrift wrapper around * org.apache.hadoop.hbase.TableName */ -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TTableName implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTableName"); diff --git a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java index a6161ec734c..b65c7796479 100644 --- a/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java +++ b/hbase-thrift/src/main/java/org/apache/hadoop/hbase/thrift2/generated/TTimeRange.java @@ -7,7 +7,7 @@ package org.apache.hadoop.hbase.thrift2.generated; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) -@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-01-27") +@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.12.0)", date = "2019-02-22") public class TTimeRange implements org.apache.thrift.TBase, java.io.Serializable, Cloneable, Comparable { private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTimeRange"); diff --git a/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift2/hbase.thrift b/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift2/hbase.thrift index ef2dae50982..4af843ad962 100644 --- a/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift2/hbase.thrift +++ b/hbase-thrift/src/main/resources/org/apache/hadoop/hbase/thrift2/hbase.thrift @@ -339,10 +339,6 @@ enum TBloomFilterType { * Bloom enabled with Table row prefix as Key, specify the length of the prefix */ ROWPREFIX_FIXED_LENGTH = 3, - /** - * Bloom enabled with Table row prefix as Key, specify the delimiter of the prefix - */ - ROWPREFIX_DELIMITED = 4 } /**