Unverified Commit 927ee609 authored by Wallace's avatar Wallace Committed by GitHub

Add interface MultiBatchWrite for TitanDB (#156)

This is a new interface which is added to RocksDB recently and TiKV will call it if `enable_multi_thread_write` of `DBOptions` is true. So Titan must implement it by self.
Signed-off-by: 's avatarLittle-Wallace <bupt2013211450@gmail.com>
parent f611dfb4
......@@ -548,6 +548,12 @@ Status TitanDBImpl::Write(const rocksdb::WriteOptions& options,
return HasBGError() ? GetBGError() : db_->Write(options, updates);
}
Status TitanDBImpl::MultiBatchWrite(const WriteOptions& options,
std::vector<WriteBatch*>&& updates) {
return HasBGError() ? GetBGError()
: db_->MultiBatchWrite(options, std::move(updates));
}
Status TitanDBImpl::Delete(const rocksdb::WriteOptions& options,
rocksdb::ColumnFamilyHandle* column_family,
const rocksdb::Slice& key) {
......
......@@ -62,6 +62,10 @@ class TitanDBImpl : public TitanDB {
using TitanDB::Write;
Status Write(const WriteOptions& options, WriteBatch* updates) override;
using TitanDB::MultiBatchWrite;
Status MultiBatchWrite(const WriteOptions& options,
std::vector<WriteBatch*>&& updates) override;
using TitanDB::Delete;
Status Delete(const WriteOptions& options, ColumnFamilyHandle* column_family,
const Slice& key) override;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment