WMTable.h

//
// Created by tony on 31/12/22.
//
 
#ifndef INTELLISTREAM_INCLUDE_WATERMARKER_WMTABLE_H_
#define INTELLISTREAM_INCLUDE_WATERMARKER_WMTABLE_H_
#include <WaterMarker/AbstractWaterMarker.h>
#include <map>
#include <string>
namespace OoOJoin {
class WMTable {
 protected:
  std::map<std::string, AbstractWaterMarkerPtr> wmMap;
 public:
  WMTable();
  ~WMTable() {}
  void registerNewWM(AbstractWaterMarkerPtr onew, std::string tag) {
    wmMap[tag] = onew;
  }
  AbstractWaterMarkerPtr findWM(std::string name) {
    if (wmMap.count(name)) {
      return wmMap[name];
    }
    return nullptr;
  }
};
 
typedef std::shared_ptr<class WMTable> WMTablePtr;
#define newWMTable std::make_shared<OoOJoin::WMTable>
}
#endif //INTELLISTREAM_INCLUDE_WATERMARKER_WMTABLE_H_