CellJoinJP.h

Go to the documentation of this file.

 
//
// Created by tony on 2022/2/8.
//
 
#ifndef _JOINPROCESSOR_CELLJOINJP_H_
#define _JOINPROCESSOR_CELLJOINJP_H_
#include <thread>
#include <Common/Types.h>
#include <Utils/UtilityFunctions.hpp>
#include <barrier>
 
#include <JoinProcessor/AbstractJP.h>
using namespace INTELLI;
using namespace std;
namespace INTELLI {
class CellJoinJP : public AbstractJP {
 private:
  /* data */
  // struct timeval timeStart;
 
  // hashtable hashtableS,hashtableR;
 protected:
  virtual void inlineMain();
 
  WindowQueue windowQueueS;
  WindowQueue windowQueueR;
 
 public:
 
  CellJoinJP() {
 
  }
  void init(size_t sLen, size_t rLen, size_t _sysId) {
    AbstractJP::init(sLen, rLen, _sysId);
    windowQueueS = newWindowQueue(sLen);
    windowQueueR = newWindowQueue(rLen);
  }
  /*SimpleHashJP(size_t sLen,size_t rLen,size_t _sysId)
  {
 
  }*/
  ~CellJoinJP() {
 
  }
  //outside feed a window
  void feedWindowS(WindowOfTuples ws) {
    windowQueueS->push(ws);
  }
  void feedWindowR(WindowOfTuples wr) {
    windowQueueR->push(wr);
  }
 
};
typedef std::shared_ptr<CellJoinJP> CellJoinJPPtr;
 
}
#endif //HYBRID_JOIN_SRC_JOINPROCESSOR_SIMPLEHASHJP_H_