AbstractWaterMarker.h

Go to the documentation of this file.

 
//
// Created by tony on 24/11/22.
//
 
#ifndef _INCLUDE_WATERMARKER_ABSTRACTWATERMARKER_H_
#define _INCLUDE_WATERMARKER_ABSTRACTWATERMARKER_H_
#include <Common/Window.h>
#include <Common/Tuples.h>
#include <Common/Window.h>
#include <Common/Tuples.h>
#include <Utils/UtilityFunctions.hpp>
#include <assert.h>
#include <Utils/ConfigMap.hpp>
 
#include <Utils/IntelliLog.h>
#define WM_INFO INTELLI_INFO
#define WM_ERROR INTELLI_ERROR
#define WM_WARNNING INTELLI_WARNING
using namespace INTELLI;
namespace OoOJoin {
class AbstractWaterMarker {
 protected:
  double errorBound;
  //tsType timeStep;
  struct timeval timeBaseStruct;
  virtual double estimateError(size_t wid = 1);
 public:
  ConfigMapPtr config = nullptr;
  AbstractWaterMarker() {}
  ~AbstractWaterMarker() {}
 
  void setErrorBound(double err) {
    errorBound = err;
  }
  void syncTimeStruct(struct timeval tv) {
    timeBaseStruct = tv;
  }
  virtual bool setConfig(ConfigMapPtr cfg);
  virtual bool init(void);
  virtual size_t creatWindow(tsType tBegin, tsType tEnd);
  virtual bool deleteWindow(size_t wid);
  virtual bool reportTupleS(TrackTuplePtr ts, size_t wid = 1);
 
  virtual bool reportTupleR(TrackTuplePtr tr, size_t wid = 1);
 
};
typedef std::shared_ptr<class AbstractWaterMarker> AbstractWaterMarkerPtr;
#define newAbstractWaterMarker std::make_shared<OoOJoin::AbstractWaterMarker>
}
#endif //INTELLISTREAM_INCLUDE_WATERMARKER_ABSTRACTWATERMARKER_H_