AbstractLazyJP.h

Go to the documentation of this file.

 
//
// Created by tony on 11/03/22.
//
 
#ifndef _JOINPROCESSOR_ABSTRACTLAZYJP_H_
#define _JOINPROCESSOR_ABSTRACTLAZYJP_H_
#include <JoinProcessor/AbstractJP.h>
#include <JoinAlgo/JoinAlgoTable.h>
#include <JoinAlgo/NPJ.h>
 
namespace INTELLI {
class AbstractLazyJP;
typedef enum {
  LWJ_IDLE = 0,
  LWJ_COLLECTING,
  LWJ_PROCESSING,
} lwj_status_t;
 
typedef std::shared_ptr<AbstractLazyJP> AbstractLazyJPPtr;
#define  newAbstractLazyJP() make_shared<AbstractLazyJP>()
class AbstractLazyJP : public AbstractJP {
 protected:
  C20Buffer<TuplePtr> windowS;
  C20Buffer<TuplePtr> windowR;
  C20Buffer<TuplePtr> windowSOverLap;
  C20Buffer<TuplePtr> windowROverLap;
  lwj_status_t statusS = LWJ_IDLE;
  lwj_status_t statusR = LWJ_IDLE;
  // size_t slide = 0;
  //size_t windowLen = 0;
 
  size_t period = 0;
  size_t tsOverlap = 0;
  size_t tsEnd = 0;
  size_t tsBegin = 0;
  /*bool sWindowReady = false;
  bool rWindowReady = false;
  bool isLastJp = false;*/
  bool checkTupleS(TuplePtr ts);
  bool checkTupleR(TuplePtr tr);
  virtual void inlineMain();
  // bool belongs2Me(size_t timeDivSys);
  bool largerThanMe(size_t timeDivSys);
  bool smallerThanMe(size_t timeDivSys);
  void moveStoBuffer();
  void moveRtoBuffer();
 public:
  AbstractLazyJP() {}
  ~ AbstractLazyJP() {}
  virtual void init(size_t sLen, size_t rLen, size_t _sysId) {
    AbstractJP::init(sLen, rLen, _sysId);
 
    windowS = C20Buffer<TuplePtr>(sLen);
    windowR = C20Buffer<TuplePtr>(rLen);
    windowSOverLap = C20Buffer<TuplePtr>(sLen);
    windowROverLap = C20Buffer<TuplePtr>(rLen);
  }
  void setLazyWindow(size_t sli, size_t wlen, size_t per) {
    // slide = sli;
    windowLen = wlen;
    setGlobalWindow(wlen, sli);
    period = per;
    tsBegin = sysId * slideLenGlobal;
    tsEnd = tsBegin + windowLenGlobal;
    tsOverlap = tsEnd - slideLenGlobal;
  }
 
};
 
}
#endif //ALIANCEDB_INCLUDE_JOINPROCESSOR_ABSTRACTLAZYJP_H_