2016-02-10 00:12:00 +01:00
|
|
|
// Copyright (c) 2011-present, Facebook, Inc. All rights reserved.
|
2013-10-16 23:59:46 +02:00
|
|
|
// This source code is licensed under the BSD-style license found in the
|
|
|
|
// LICENSE file in the root directory of this source tree. An additional grant
|
|
|
|
// of patent rights can be found in the PATENTS file in the same directory.
|
|
|
|
//
|
2012-04-17 17:36:46 +02:00
|
|
|
// Copyright (c) 2012 The LevelDB Authors. All rights reserved.
|
|
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
|
|
// found in the LICENSE file. See the AUTHORS file for names of contributors.
|
|
|
|
//
|
|
|
|
// A filter block is stored near the end of a Table file. It contains
|
|
|
|
// filters (e.g., bloom filters) for all data blocks in the table combined
|
|
|
|
// into a single filter block.
|
2014-09-08 19:37:05 +02:00
|
|
|
//
|
|
|
|
// It is a base class for BlockBasedFilter and FullFilter.
|
|
|
|
// These two are both used in BlockBasedTable. The first one contain filter
|
|
|
|
// For a part of keys in sst file, the second contain filter for all keys
|
|
|
|
// in sst file.
|
2012-04-17 17:36:46 +02:00
|
|
|
|
2013-10-05 07:32:05 +02:00
|
|
|
#pragma once
|
2013-11-13 07:46:51 +01:00
|
|
|
|
2014-08-16 00:05:09 +02:00
|
|
|
#include <memory>
|
2012-04-17 17:36:46 +02:00
|
|
|
#include <stddef.h>
|
|
|
|
#include <stdint.h>
|
|
|
|
#include <string>
|
|
|
|
#include <vector>
|
2014-09-08 19:37:05 +02:00
|
|
|
#include "rocksdb/options.h"
|
2013-08-23 17:38:13 +02:00
|
|
|
#include "rocksdb/slice.h"
|
2014-08-16 00:05:09 +02:00
|
|
|
#include "rocksdb/slice_transform.h"
|
2014-08-25 23:22:05 +02:00
|
|
|
#include "rocksdb/table.h"
|
2014-08-16 00:05:09 +02:00
|
|
|
#include "util/hash.h"
|
|
|
|
#include "format.h"
|
2012-04-17 17:36:46 +02:00
|
|
|
|
2013-10-04 06:49:15 +02:00
|
|
|
namespace rocksdb {
|
2012-04-17 17:36:46 +02:00
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
const uint64_t kNotValid = ULLONG_MAX;
|
2014-08-16 00:05:09 +02:00
|
|
|
class FilterPolicy;
|
2012-04-17 17:36:46 +02:00
|
|
|
|
|
|
|
// A FilterBlockBuilder is used to construct all of the filters for a
|
|
|
|
// particular Table. It generates a single string which is stored as
|
|
|
|
// a special block in the Table.
|
|
|
|
//
|
|
|
|
// The sequence of calls to FilterBlockBuilder must match the regexp:
|
2014-09-08 19:37:05 +02:00
|
|
|
// (StartBlock Add*)* Finish
|
|
|
|
//
|
|
|
|
// BlockBased/Full FilterBlock would be called in the same way.
|
2012-04-17 17:36:46 +02:00
|
|
|
class FilterBlockBuilder {
|
|
|
|
public:
|
2014-09-08 19:37:05 +02:00
|
|
|
explicit FilterBlockBuilder() {}
|
|
|
|
virtual ~FilterBlockBuilder() {}
|
2012-04-17 17:36:46 +02:00
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
virtual bool IsBlockBased() = 0; // If is blockbased filter
|
|
|
|
virtual void StartBlock(uint64_t block_offset) = 0; // Start new block filter
|
|
|
|
virtual void Add(const Slice& key) = 0; // Add a key to current filter
|
|
|
|
virtual Slice Finish() = 0; // Generate Filter
|
2012-04-17 17:36:46 +02:00
|
|
|
|
|
|
|
private:
|
|
|
|
// No copying allowed
|
|
|
|
FilterBlockBuilder(const FilterBlockBuilder&);
|
|
|
|
void operator=(const FilterBlockBuilder&);
|
|
|
|
};
|
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
// A FilterBlockReader is used to parse filter from SST table.
|
|
|
|
// KeyMayMatch and PrefixMayMatch would trigger filter checking
|
|
|
|
//
|
|
|
|
// BlockBased/Full FilterBlock would be called in the same way.
|
2012-04-17 17:36:46 +02:00
|
|
|
class FilterBlockReader {
|
|
|
|
public:
|
2016-06-10 00:48:45 +02:00
|
|
|
explicit FilterBlockReader()
|
|
|
|
: whole_key_filtering_(true), size_(0), statistics_(nullptr) {}
|
|
|
|
explicit FilterBlockReader(size_t s, Statistics* stats,
|
|
|
|
bool _whole_key_filtering)
|
|
|
|
: whole_key_filtering_(_whole_key_filtering),
|
|
|
|
size_(s),
|
|
|
|
statistics_(stats) {}
|
2014-09-08 19:37:05 +02:00
|
|
|
virtual ~FilterBlockReader() {}
|
2013-11-13 07:46:51 +01:00
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
virtual bool IsBlockBased() = 0; // If is blockbased filter
|
|
|
|
virtual bool KeyMayMatch(const Slice& key,
|
|
|
|
uint64_t block_offset = kNotValid) = 0;
|
|
|
|
virtual bool PrefixMayMatch(const Slice& prefix,
|
|
|
|
uint64_t block_offset = kNotValid) = 0;
|
|
|
|
virtual size_t ApproximateMemoryUsage() const = 0;
|
2016-06-03 19:47:47 +02:00
|
|
|
virtual size_t size() const { return size_; }
|
|
|
|
virtual Statistics* statistics() const { return statistics_; }
|
2013-08-13 23:04:56 +02:00
|
|
|
|
2016-06-10 00:48:45 +02:00
|
|
|
bool whole_key_filtering() const { return whole_key_filtering_; }
|
|
|
|
|
2014-12-23 22:24:07 +01:00
|
|
|
// convert this object to a human readable form
|
|
|
|
virtual std::string ToString() const {
|
|
|
|
std::string error_msg("Unsupported filter \n");
|
|
|
|
return error_msg;
|
|
|
|
}
|
|
|
|
|
2016-06-10 00:48:45 +02:00
|
|
|
protected:
|
|
|
|
bool whole_key_filtering_;
|
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
private:
|
|
|
|
// No copying allowed
|
|
|
|
FilterBlockReader(const FilterBlockReader&);
|
|
|
|
void operator=(const FilterBlockReader&);
|
2016-06-03 19:47:47 +02:00
|
|
|
size_t size_;
|
|
|
|
Statistics* statistics_;
|
2012-04-17 17:36:46 +02:00
|
|
|
};
|
|
|
|
|
2014-09-08 19:37:05 +02:00
|
|
|
} // namespace rocksdb
|