SplitJoinIRJP.h

Go to the documentation of this file.

 
//
// Created by tony on 22/03/22.
//
 
#ifndef _JOINPROCESSOR_SPLITJOINIRJP_H_
#define _JOINPROCESSOR_SPLITJOINIRJP_H_
#include <thread>
#include <Common/Types.h>
#include <Utils/UtilityFunctions.hpp>
#include <barrier>
 
#include <JoinProcessor/SplitJoinJP.h>
#include <Utils/DupicatedHashTable.hpp>
using namespace INTELLI;
using namespace std;
namespace INTELLI {
typedef INTELLI::DupicatedHashTable<keyType, keyType> dpHashtable;
//typedef <keyType, keyType> dpHashtable;
typedef shared_ptr<dpHashtable> dpHashtablePtr;
class SplitJoinIRJP : public SplitJoinJP {
 
 protected:
  dpHashtablePtr hashtableS, hashtableR;
  virtual void inlineMain();
 
  void expireS(size_t cond);
  void expireR(size_t cond);
  void joinS(TuplePtr ts);
  void joinR(TuplePtr tr);
 public:
  SplitJoinIRJP() {
 
  }
  ~SplitJoinIRJP() {
 
  }
  void init(size_t sLen, size_t rLen, size_t _sysId) {
    SplitJoinJP::init(sLen, rLen, _sysId);
    //windowS = C20Buffer<TuplePtr>(sLen);
    // windowR = C20Buffer<TuplePtr>(rLen)
  }
 
};
typedef std::shared_ptr<SplitJoinIRJP> SplitJoinIRJPPtr;
}
#endif //ALIANCEDB_INCLUDE_JOINPROCESSOR_SPLITJP_H_