LatenessWM.h

Go to the documentation of this file.

 
//
// Created by tony on 25/11/22.
//
 
#ifndef _INCLUDE_WATERMARKER_LATENESSWM_H_
#define _INCLUDE_WATERMARKER_LATENESSWM_H_
#include <WaterMarker/AbstractWaterMarker.h>
namespace OoOJoin {
class LatenessWM : public AbstractWaterMarker {
 protected:
  tsType lateness = 0;
  tsType earlierEmit = 0;
 
  tsType windowUpperBound = 0;
  tsType maxEventTime = 0;
  bool isReachWMPoint(TrackTuplePtr tp);
 public:
  LatenessWM() {}
  ~LatenessWM() {}
 
  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 LatenessWM> LatenessWMPtr;
#define newLatenessWM std::make_shared<OoOJoin::LatenessWM>
}
#endif //INTELLISTREAM_INCLUDE_WATERMARKER_PERIODICALWM_H_