AbstractLazyWS.h

Go to the documentation of this file.

 
//
// Created by tony on 10/03/22.
//
 
#ifndef _WINDOWSLIDER_ABSTRACTLAZYWS_H_
#define _WINDOWSLIDER_ABSTRACTLAZYWS_H_
#include <Common/Types.h>
#include <WindowSlider/AbstractWS.h>
#include <JoinProcessor/AbstractLazyJP.h>
namespace INTELLI {
class AbstractLazyWS : public AbstractWS, public AbstractC20Thread {
 protected:
  vector<AbstractLazyJPPtr> jps;
  size_t period = 0;
  size_t windowCnt = 0;
  virtual void inlineMain();
 
 public:
  AbstractLazyWS() {
    reset();
    nameTag = "LWJ";
  }
 
  AbstractLazyWS(size_t sLen, size_t rLen) : AbstractWS(sLen, rLen) {
    nameTag = "LWJ";
  }
 
  //init the join processors
  virtual void initJoinProcessors();
 
  virtual void terminateJoinProcessors();
 
  virtual void waitAckFromJoinProcessors();
 
  //get the join result
  virtual size_t getJoinResult();
 
};
}
 
#endif //ALIANCEDB_SRC_WINDOWSLIDER_ABSTRACTLAZYWS_H_