hashjoin.h

Go to the documentation of this file.

/*
 * SwatDB
 *
 * @authors: See Contributors.doc for code contributors
 *
 * Copyright (c) 2020, 2025 Swarthmore College Computer Science Department
 * Swarthmore PA, Professors Tia Newhall, Ameet Soni
 */
 
// @@@@ SWATDB_ASSIGNMENT: ADDTODODATE
 
#ifndef  _SWATDB_HASHJOIN_H_
#define  _SWATDB_HASHJOIN_H_
 
#include <string>
#include <vector>
#include "swatdb_types.h"
#include "join.h"
 
class FileManager;
class Catalog;
class Schema;
class File;
class RelationFile;
class HeapFileScanner;
class BlockHeapFileScanner;
class HeapFile;
class Record;
class Data;
class Key;
 
// @@@@ SWATDB_ASSIGNMENT: NOTEMSG Do not modify this definition, you may add private helper methods only
 
class HashJoin : public Join {
 
  public:
 
    HashJoin(FileId outer_id, FileId inner_id, FileId result_id,
        std::vector<FieldId> outer_fields, 
        std::vector<FieldId> inner_fields,  
        std::uint32_t num_buckets, 
        std::string temp_path, Catalog *catalog, BufferManager *buf_mgr,
        FileManager *file_mgr);
 
    ~HashJoin();
 
    void runOperation();
 
  protected:
 
    BufferManager *buf_mgr;
 
    FileManager *file_mgr;
   
    std::vector<HeapFile *> outer_partitions;
 
    std::vector<HeapFile *> inner_partitions;
 
    std::uint32_t num_buckets;
 
    std::vector<std::pair<HeapPage *, PageId>> hash_table;
    
    std::string temp_path;
 
 
    //TODO replace
    std::uint32_t result_num;
 
    std::uint32_t hash1(Record *rec, bool is_outer);
    
    void _createTempFiles(); 
 
 
    void _firstHash(bool is_outer); 
 
    void _secondHash();
 
    RecordId _part1(Record* record, bool is_outer, 
    BlockHeapFileScanner *scanner);
 
    void cleanup();
};
 
#endif