parallelHashJoin.h

Go to the documentation of this file.

/*
 * SwatDB
 *
 * @authors: See Contributors.doc for code contributors
 *
 * Copyright (c) 2020 Swarthmore College Computer Science Department
 * Swarthmore PA, Professors Tia Newhall, Ameet Soni
 */
 
#ifndef  _SWATDB_PARALLELHASHJOIN_H_
#define  _SWATDB_PARALLELHASHJOIN_H_
 
#include <string>
#include <vector>
#include <thread>
#include <mutex>
#include <condition_variable>
#include "swatdb_types.h"
#include "hashjoin.h"
 
class FileManager;
class Catalog;
class Schema;
class File;
class RelationFile;
class HeapFileScanner;
class BlockHeapFileScanner;
class HeapFile;
class Record;
class Data;
class Key;
 
class ParallelHashJoin : public HashJoin {
 
  public:
 
    ParallelHashJoin(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::uint32_t num_threads,
        std::string temp_path, Catalog *catalog, BufferManager *buf_mgr,
        FileManager *file_mgr);
 
    ~ParallelHashJoin();
 
    void runOperation();
 
  private:
 
 
    std::uint32_t num_threads;
 
    //TODO replace
    std::uint32_t result_num;
 
    std::mutex *mtx_table;
 
    std::mutex mtx;
 
    std::condition_variable cv;
 
    std::uint32_t tcount;
 
    std::exception_ptr thd_exc_ptr;
 
    std::mutex exc_mtx;
 
    std::vector<std::thread> threads;
    
 
    void _firstHash(std::uint32_t tid, bool is_outer); 
 
    void _secondHash(std::uint32_t tid, std::uint32_t n_threads);
 
    RecordId _parallelPart1(Record* record, bool is_outer, BlockHeapFileScanner *scanner);
 
    void _barrier(std::uint32_t n_threads);
 
    void _parallelRun(std::uint32_t tid);
 
};
 
#endif