ArrivalWM.h

Go to the documentation of this file.

 
//
// Created by tony on 25/11/22.
//
 
#ifndef _INCLUDE_WATERMARKER_ArrivalWM_H_
#define _INCLUDE_WATERMARKER_ArrivalWM_H_
#include <WaterMarker/AbstractWaterMarker.h>
namespace OoOJoin {
class ArrivalWM : public AbstractWaterMarker {
 protected:
  tsType watermarkTime = 0;
  tsType nextWMDelta = 0;
  tsType windowLen = 0;
  tsType nextWMPoint = 0;
//  tsType maxEventTime=0;
  bool isReachWMPoint(TrackTuplePtr tp);
 public:
  ArrivalWM() {}
  ~ArrivalWM() {}
 
  virtual bool setConfig(ConfigMapPtr cfg);
  virtual size_t creatWindow(tsType tBegin, tsType tEnd);
  virtual bool reportTupleS(TrackTuplePtr ts, size_t wid = 1);
 
  virtual bool reportTupleR(TrackTuplePtr tr, size_t wid = 1);
};
typedef std::shared_ptr<class ArrivalWM> ArrivalWMPtr;
#define newArrivalWM std::make_shared<OoOJoin::ArrivalWM>
}
#endif //INTELLISTREAM_INCLUDE_WATERMARKER_ArrivalWM_H_