Packages

rocksdb

0.26.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 utilities column_aware_encoding_util.h
Raw

deps/rocksdb/utilities/column_aware_encoding_util.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

#ifndef ROCKSDB_LITE



#include <string>

#include <vector>

#include "db/dbformat.h"

#include "include/rocksdb/env.h"

#include "include/rocksdb/listener.h"

#include "include/rocksdb/options.h"

#include "include/rocksdb/status.h"

#include "options/cf_options.h"

#include "table/block_based_table_reader.h"



namespace rocksdb {



struct ColDeclaration;

struct KVPairColDeclarations;



class ColumnAwareEncodingReader {

 public:

  explicit ColumnAwareEncodingReader(const std::string& file_name);



  void GetKVPairsFromDataBlocks(std::vector<KVPairBlock>* kv_pair_blocks);



  void EncodeBlocksToRowFormat(WritableFile* out_file,

                               CompressionType compression_type,

                               const std::vector<KVPairBlock>& kv_pair_blocks,

                               std::vector<std::string>* blocks);



  void DecodeBlocksFromRowFormat(WritableFile* out_file,

                                 const std::vector<std::string>* blocks);



  void DumpDataColumns(const std::string& filename,

                       const KVPairColDeclarations& kvp_col_declarations,

                       const std::vector<KVPairBlock>& kv_pair_blocks);



  Status EncodeBlocks(const KVPairColDeclarations& kvp_col_declarations,

                      WritableFile* out_file, CompressionType compression_type,

                      const std::vector<KVPairBlock>& kv_pair_blocks,

                      std::vector<std::string>* blocks, bool print_column_stat);



  void DecodeBlocks(const KVPairColDeclarations& kvp_col_declarations,

                    WritableFile* out_file,

                    const std::vector<std::string>* blocks);



  static void GetColDeclarationsPrimary(

      std::vector<ColDeclaration>** key_col_declarations,

      std::vector<ColDeclaration>** value_col_declarations,

      ColDeclaration** value_checksum_declaration);



  static void GetColDeclarationsSecondary(

      std::vector<ColDeclaration>** key_col_declarations,

      std::vector<ColDeclaration>** value_col_declarations,

      ColDeclaration** value_checksum_declaration);



 private:

  // Init the TableReader for the sst file

  void InitTableReader(const std::string& file_path);



  std::string file_name_;

  EnvOptions soptions_;



  Options options_;



  Status init_result_;

  std::unique_ptr<BlockBasedTable> table_reader_;

  std::unique_ptr<RandomAccessFileReader> file_;



  const ImmutableCFOptions ioptions_;

  const MutableCFOptions moptions_;

  InternalKeyComparator internal_comparator_;

  std::unique_ptr<TableProperties> table_properties_;

};



}  // namespace rocksdb



#endif  // ROCKSDB_LITE