AbstractEagerWS.h

Go to the documentation of this file.

 
#ifndef WINDOWSLIDER_ABSTRACTEAGERWS_H_
#define WINDOWSLIDER_ABSTRACTEAGERWS_H_
 
#include <WindowSlider/AbstractWS.h>
#include <JoinProcessor/CellJoinJP.h>
#include <Utils/AbstractC20Thread.h>
using namespace INTELLI;
using namespace std;
namespace INTELLI {
//Note: "Upon every arrival of a tuple, the opposing window is re-partitioned to perform a parallel scan"
class AbstractEagerWS : public AbstractWS, public AbstractC20Thread {
 private:
  /* data */
  std::vector<CellJoinJPPtr> jps;
 protected:
  void expireS(size_t cond);
  void expireR(size_t cond);
  TuplePtrQueue TuplePtrQueueLocalS;
  TuplePtrQueue TuplePtrQueueLocalR;
  virtual void inlineMain();
  void deliverTupleS(TuplePtr ts);
  void deliverTupleR(TuplePtr tr);
 
 public:
  //generate the partition vector of offset
  vector<size_t> weightedPartitionSizeFinal(size_t inS); //reserved for AMP
  vector<size_t> avgPartitionSizeFinal(size_t inS); //for SMP
 
  AbstractEagerWS() {
    reset();
    nameTag = "CellJoin";
  }
 
  //init with length of queue
  AbstractEagerWS(size_t sLen, size_t rLen);
  //feed the tuple S
 
  ~AbstractEagerWS();
 
  //init the join processors
  void initJoinProcessors();
  void terminateJoinProcessors();
  void waitAckFromJoinProcessors();
  //get the join result
  size_t getJoinResult();
 
  //startTime
};
}
#endif