AbstractOperator.h

Go to the documentation of this file.

 
//
// Created by tony on 22/11/22.
//
 
#ifndef ADB_INCLUDE_OPERATOR_ABSTRACTOPERATOR_H_
#define ADB_INCLUDE_OPERATOR_ABSTRACTOPERATOR_H_
#include <Common/Window.h>
#include <Common/Tuples.h>
#include <Utils/UtilityFunctions.hpp>
#include <assert.h>
#include <Utils/ConfigMap.hpp>
#include <WaterMarker/WMTable.h>
//#include <Utils/Logger.hpp>
#define OP_INFO printf
#define OP_ERROR printf
#define OP_WARNNING INTELLI_WARNING
 
using namespace INTELLI;
namespace OoOJoin {
class AbstractOperator {
 protected:
  struct timeval timeBaseStruct;
  size_t windowLen = 0;
  size_t slideLen = 0;
  size_t sLen = 0, rLen = 0;
  int threads = 0;
  tsType timeStep = 0;
  tsType timeBreakDown_all = 0;
  void setFinalProcessedTime();
 public:
  ConfigMapPtr config = nullptr;
  AbstractOperator() {}
  ~AbstractOperator() {}
 
  void setWindow(size_t _wl, size_t _sli) {
    windowLen = _wl;
    slideLen = _sli;
  }
  void setBufferLen(size_t _sLen, size_t _rLen) {
    sLen = _sLen;
    rLen = _rLen;
  }
 
  void syncTimeStruct(struct timeval tv) {
    timeBaseStruct = tv;
  }
  virtual bool setConfig(ConfigMapPtr cfg);
  virtual bool feedTupleS(TrackTuplePtr ts);
 
  virtual bool feedTupleR(TrackTuplePtr tr);
 
  virtual bool start();
 
  virtual bool stop();
 
  virtual size_t getResult();
  virtual size_t getAQPResult();
  virtual ConfigMapPtr getTimeBreakDown();
};
typedef std::shared_ptr<class AbstractOperator> AbstractOperatorPtr;
#define newAbstractOperator std::make_shared<OoOJoin::AbstractOperator>
#define timeTrackingStart(v); tsType v;v=UtilityFunctions::timeLastUs(timeBaseStruct);
#define timeTrackingStartNoClaim(v); v=UtilityFunctions::timeLastUs(timeBaseStruct);
#define timeTrackingEnd(v) (UtilityFunctions::timeLastUs(timeBaseStruct)-v)
 
}
#endif //INTELLISTREAM_INCLUDE_OPERATOR_ABSTRACTOPERATOR_H_