CMU15-445/645学习笔记

发表于 更新于 分类于

CMU15-445/645

src/common.

channel.h

  • 实际上是一个线程安全队列.

rid.h

  • Record Identifier = page_id_ << 32 | slot_num_

rwlatch.h

  • 读写锁(std::shared_mutex)

src/type.

abstract_pool.h

  • 抽象内存池接口

type_id.h

  • type枚举 
    1
    enum TypeId { INVALID = 0, BOOLEAN, TINYINT, SMALLINT, INTEGER, BIGINT, DECIMAL, VARCHAR, TIMESTAMP };

type.h

  • 类型基类.
  • 定义了类型比较,运算,序列化,转换类型等虚接口.

boolean_type.h

  • 实例化boolean类型比较,运算,序列化,转换类型等接口.

numeraic_type.h

  • number value的基类,可以是整数和小数.必须提供运算操作.

integer_parent_type.h

  • 为整数提供具有鲁棒性的四则运算.

tinyint_type.h,smallint_type.h,bigint_type.hinteger_type.h

  • integer_parent_type的子类,为整数提供了比较,运算,序列化,转换类型等接口.

timestamp_type.h

  • 为timestamp类型提供比较等接口.

decimal_type.h

  • 为小数提供类型比较,运算,序列化,转换类型等接口.

value.h

  • 实际管理数据内容的地方.
  • 存储着type和数据内容.
  • value比较,运算,序列化,转换类型等操作都是调用type提供的虚接口. 
    1
    Type::GetInstance(type_id_)->

value_factory.h

  • value工厂类,方便构造value.

src/catalog.

column.h

  • 记录column的name,type,fixed_length,variable_length,offset.

schema.h

  • 存储着std::vector columns. 记录数据库tuple的元信息.

catalog.h

  • 处理表创建、表查找、索引创建和索引查找.

src/storage.

table/tuple.h

  • 存储RID rid_{},std::vector data_.
  • 定义了tuple的存储格式,前面部分存储inline数据,然后存储uninline数据.
  • 可以通过schema和column_idx得到数据.

table/table_heap.h

  • BufferPoolManager *bpm_,page_id_t first_page_id_,page_id_t last_page_id_.
  • 通过BufferPoolManager操作table,提供了一系列操作table中tuple的接口.

table/table_iterator.h

  • table中page的迭代器.

disk/disk_manager.h

  • 封装了写文件操作.
  • file_name_,log_name_.
  • 通过page_id计算offset,然后往文件读写内容.

disk/disk_scheduler.h

  • 内部保存DiskManager.
  • Channel<std::optional> request_queue_,使用channel依次处理请求.

page/page.h

  • 数据库存储的基本单元.提供了对真实数据页的一层包装.
  • data_,page_id_,pin_count_,is_dirty_,rwlatch_.

page/page_guard.h

  • 为page提供RAII.

page/table_page.h

  • 一个page是怎么存储tuple的.

page/extendible_htable_header_page.h

  • page_id_t directory_page_ids_[512],uint32_t max_depth_;
  • 固定大小,可以认为是第一层hash,有一个常量max_depth_.

page/extendible_htable_directory_page.h

  • uint32_t max_depth_,uint32_t global_depth_,uint8_t local_depths_[512],page_id_t bucket_page_ids_[512];
  • 不固定大小,可以认为是第二层hash,有一个变量depth.

page/extendible_htable_bucket_page.h

  • uint32_t size_,uint32_t max_size_,MappingType array_[HTableBucketArraySize(sizeof(MappingType))];
  • 保存实际value的地方.

index/index.h

  • std::unique_ptr metadata_;
  • IndexMetadata 
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    /** The name of the index */
    std::string name_;
    /** The name of the table on which the index is created */
    std::string table_name_;
    /** The mapping relation between key schema and tuple schema */
    const std::vector<uint32_t> key_attrs_;
    /** The schema of the indexed key */
    std::shared_ptr<Schema> key_schema_;
    /** Is primary key? */
    bool is_primary_key_;
  • 索引的抽象基类.

index/extendible_hash_table_index.h

  • class ExtendibleHashTableIndex : public Index;
  • 根据extendible_hash_table构建的索引表.

src/buffer.

lru_k_replacer.h

  • 实现了lru_k替换算法.

buffer_pool_manager.h

  • 缓存池.通过pool_size,disk_manager(file_name_),replacer_k初始化.

src/container.

disk/hash/disk_extendible_hash_table.h

  • std::string index_name_;BufferPoolManager *bpm_;KC cmp_;HashFunction hash_fn_;uint32_t header_max_depth_;uint32_t directory_max_depth_;uint32_t bucket_max_size_;page_id_t header_page_id_;
  • 结合BufferPoolManager,extendible_htable_header_page,extendible_htable_directory_page,extendible_htable_bucket_page,建立一个可动态扩展/收缩的HashTable，对外提供增、删、查的的服务接口.

execution

executors/abstract_executor.h

  • 执行器的抽象基类.