Packages

rocksdb

2.4.1
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
63 Versions
0 Dependencies
Dependants
Files
Activity
rocksdb deps rocksdb util simple_mixed_compressor.h
Raw

deps/rocksdb/util/simple_mixed_compressor.h 

//  Copyright (c) Meta Platforms, Inc. and affiliates.

//  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).

//

// Creates mixed compressor wrapper which uses multiple compression algorithm

// within same SST file.



#pragma once

#include <memory>

#include <vector>



#include "compression.h"

#include "rocksdb/advanced_compression.h"



namespace ROCKSDB_NAMESPACE {



class MultiCompressorWrapper : public Compressor {

 public:

  explicit MultiCompressorWrapper(const CompressionOptions& opts,

                                  CompressionDict&& dict = {});



  size_t GetMaxSampleSizeIfWantDict(CacheEntryRole block_type) const override;

  Slice GetSerializedDict() const override;

  CompressionType GetPreferredCompressionType() const override;

  ManagedWorkingArea ObtainWorkingArea() override;

  std::unique_ptr<Compressor> MaybeCloneSpecialized(

      CacheEntryRole block_type, DictSampleArgs&& dict_samples) override;



 protected:

  std::vector<std::unique_ptr<Compressor>> compressors_;

};



struct RandomMixedCompressor : public MultiCompressorWrapper {

  using MultiCompressorWrapper::MultiCompressorWrapper;

  const char* Name() const override;

  Status CompressBlock(Slice uncompressed_data, char* compressed_output,

                       size_t* compressed_output_size,

                       CompressionType* out_compression_type,

                       ManagedWorkingArea* wa) override;

};



class RandomMixedCompressionManager : public CompressionManagerWrapper {

  using CompressionManagerWrapper::CompressionManagerWrapper;

  const char* Name() const override;

  std::unique_ptr<Compressor> GetCompressorForSST(

      const FilterBuildingContext& context, const CompressionOptions& opts,

      CompressionType preferred) override;

};



struct RoundRobinCompressor : public MultiCompressorWrapper {

  using MultiCompressorWrapper::MultiCompressorWrapper;

  const char* Name() const override;

  Status CompressBlock(Slice uncompressed_data, char* compressed_output,

                       size_t* compressed_output_size,

                       CompressionType* out_compression_type,

                       ManagedWorkingArea* wa) override;

  static RelaxedAtomic<uint64_t> block_counter;

};



class RoundRobinManager : public CompressionManagerWrapper {

  using CompressionManagerWrapper::CompressionManagerWrapper;

  const char* Name() const override;

  std::unique_ptr<Compressor> GetCompressorForSST(

      const FilterBuildingContext& context, const CompressionOptions& opts,

      CompressionType preferred) override;

};



}  // namespace ROCKSDB_NAMESPACE