Window.h

Go to the documentation of this file.

 
//
// Created by tony on 22/11/22.
//
 
#ifndef INTELLISTREAM_INCLUDE_COMMON_WINDOW_H_
#define INTELLISTREAM_INCLUDE_COMMON_WINDOW_H_
#include <Common/Tuples.h>
#include <Utils/C20Buffers.hpp>
namespace OoOJoin {
 
class Window {
 protected:
  size_t windowID = 0;
  tsType startTime = 0;
  tsType endTime = 0;
 public:
  Window() {}
  Window(tsType ts, tsType te);
  void setRange(tsType ts, tsType te);
  ~Window() {}
  INTELLI::C20Buffer<OoOJoin::TrackTuplePtr> windowS;
  INTELLI::C20Buffer<OoOJoin::TrackTuplePtr> windowR;
  void init(size_t sLen, size_t rLen, size_t _sysId);
  bool feedTupleS(TrackTuplePtr ts);
  bool feedTupleR(TrackTuplePtr tr);
  bool reset(void);
  tsType getStart() {
    return startTime;
  }
  tsType getEnd() {
    return endTime;
  }
};
}
#endif //INTELLISTREAM_INCLUDE_COMMON_WINDOW_H_