aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/rocksdb
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2021-07-22 23:35:54 -0700
committerGitHub <noreply@github.com>2021-07-22 23:35:54 -0700
commitbdb632fa62bf8d198a672e3a2bc88ffeb4e2e5ba (patch)
tree4fad75e3276840d03dd5ce85e208327aa87b51fa /weed/filer/rocksdb
parent60f5c0a2f57748727b236c09377d02a06b7b4aaa (diff)
parent2b46df13f862b99d671edbaec96d2cad26f8ed55 (diff)
downloadseaweedfs-bdb632fa62bf8d198a672e3a2bc88ffeb4e2e5ba.tar.xz
seaweedfs-bdb632fa62bf8d198a672e3a2bc88ffeb4e2e5ba.zip
Merge pull request #2211 from qieqieplus/filer-bloom-filter
add bloom filter for filer leveldb/rocksdb
Diffstat (limited to 'weed/filer/rocksdb')
-rw-r--r--weed/filer/rocksdb/rocksdb_store.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/weed/filer/rocksdb/rocksdb_store.go b/weed/filer/rocksdb/rocksdb_store.go
index 379a18c62..729da7d9b 100644
--- a/weed/filer/rocksdb/rocksdb_store.go
+++ b/weed/filer/rocksdb/rocksdb_store.go
@@ -24,18 +24,21 @@ func init() {
type options struct {
opt *gorocksdb.Options
+ bto *gorocksdb.BlockBasedTableOptions
ro *gorocksdb.ReadOptions
wo *gorocksdb.WriteOptions
}
func (opt *options) init() {
opt.opt = gorocksdb.NewDefaultOptions()
+ opt.bto = gorocksdb.NewDefaultBlockBasedTableOptions()
opt.ro = gorocksdb.NewDefaultReadOptions()
opt.wo = gorocksdb.NewDefaultWriteOptions()
}
func (opt *options) close() {
opt.opt.Destroy()
+ opt.bto.Destroy()
opt.ro.Destroy()
opt.wo.Destroy()
}
@@ -69,6 +72,11 @@ func (store *RocksDBStore) initialize(dir string) (err error) {
store.opt.SetCompactionFilter(NewTTLFilter())
// store.opt.SetMaxBackgroundCompactions(2)
+ // https://github.com/tecbot/gorocksdb/issues/132
+ store.bto.SetFilterPolicy(gorocksdb.NewBloomFilterFull(8))
+ store.opt.SetBlockBasedTableFactory(store.bto)
+ // store.opt.EnableStatistics()
+
store.db, err = gorocksdb.OpenDb(store.opt, dir)
return