Packages

rocksdb

0.23.3
3.1.2 3.1.1 3.1.0 3.0.0 2.6.2 2.6.1 retired 2.6.0 retired 2.5.0 2.4.1 2.4.0 2.3.0 2.2.0 2.1.0 2.0.0 1.9.0 1.8.0 1.7.0 1.6.0 1.5.1 1.5.0 1.4.0 1.3.2 1.3.1 1.3.0 1.2.0 1.1.1 1.1.0 1.0.0 0.26.2 0.26.1 0.26.0 0.25.0 0.24.0 0.23.3 0.23.2 0.23.1 0.23.0 0.22.0 0.21.0 0.20.1 0.20.0 0.19.0 0.18.0 0.17.0 0.16.0 0.15.0 0.14.0 0.13.1 0.13.0 0.12.0 0.11.0 0.10.0 0.9.1 0.9.0 0.8.2 0.8.1 0.8.0 0.7.1 0.7.0 0.6.4 0.6.3 0.6.2 0.6.1 0.6.0

RocksDB for Erlang

HexDocs

Current section

Files

Jump to
Readme
64 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb include rocksdb flush_block_policy.h
Raw

deps/rocksdb/include/rocksdb/flush_block_policy.h 

// Copyright (c) 2011-present, Facebook, Inc.  All rights reserved.

//  This source code is licensed under both the GPLv2 (found in the

//  COPYING file in the root directory) and Apache 2.0 License

//  (found in the LICENSE.Apache file in the root directory).



#pragma once



#include <string>

#include "rocksdb/table.h"



namespace rocksdb {



class Slice;

class BlockBuilder;

struct Options;



// FlushBlockPolicy provides a configurable way to determine when to flush a

// block in the block based tables,

class FlushBlockPolicy {

 public:

  // Keep track of the key/value sequences and return the boolean value to

  // determine if table builder should flush current data block.

  virtual bool Update(const Slice& key,

                      const Slice& value) = 0;



  virtual ~FlushBlockPolicy() { }

};



class FlushBlockPolicyFactory {

 public:

  // Return the name of the flush block policy.

  virtual const char* Name() const = 0;



  // Return a new block flush policy that flushes data blocks by data size.

  // FlushBlockPolicy may need to access the metadata of the data block

  // builder to determine when to flush the blocks.

  //

  // Callers must delete the result after any database that is using the

  // result has been closed.

  virtual FlushBlockPolicy* NewFlushBlockPolicy(

      const BlockBasedTableOptions& table_options,

      const BlockBuilder& data_block_builder) const = 0;



  virtual ~FlushBlockPolicyFactory() { }

};



class FlushBlockBySizePolicyFactory : public FlushBlockPolicyFactory {

 public:

  FlushBlockBySizePolicyFactory() {}



  const char* Name() const override { return "FlushBlockBySizePolicyFactory"; }



  FlushBlockPolicy* NewFlushBlockPolicy(

      const BlockBasedTableOptions& table_options,

      const BlockBuilder& data_block_builder) const override;



  static FlushBlockPolicy* NewFlushBlockPolicy(

      const uint64_t size, const int deviation,

      const BlockBuilder& data_block_builder);

};



}  // rocksdb