AbstractJoinAlgo.h

Go to the documentation of this file.

 
//
// Created by tony on 11/03/22.
//
 
#ifndef _JOINALGO_ABSTRACTJOINALGO_H_
#define _JOINALGO_ABSTRACTJOINALGO_H_
#include <Common/Window.h>
#include <string>
#include <memory>
#include <assert.h>
#include <Utils/ConfigMap.hpp>
//#include <Utils/Logger.hpp>/
using namespace INTELLI;
#define ALGO_INFO INTELLI_INFO
#define ALGO_ERROR INTELLI_ERROR
#define ALGO_WARNNING INTELLI_WARNING
namespace OoOJoin {
class AbstractJoinAlgo {
 protected:
  std::string nameTag;
  struct timeval timeBaseStruct;
  //tsType timeStep;
 public:
  ConfigMapPtr config;
  AbstractJoinAlgo() {
    setAlgoName("NULL");
  }
  ~AbstractJoinAlgo() {}
  virtual bool setConfig(ConfigMapPtr cfg);
  virtual size_t join(C20Buffer<OoOJoin::TrackTuplePtr> windS,
                      C20Buffer<OoOJoin::TrackTuplePtr> windR,
                      int threads = 1);
  void setAlgoName(std::string name) {
    nameTag = name;
  }
  std::string getAlgoName() {
    return nameTag;
  }
 
  void syncTimeStruct(struct timeval tv) {
    timeBaseStruct = tv;
  }
};
 
typedef std::shared_ptr<AbstractJoinAlgo> AbstractJoinAlgoPtr;
#define  newAbstractJoinAlgo() std::make_shared<AbstractJoinAlgo>()
}
 
#endif //ALIANCEDB_INCLUDE_JOINALGO_ABSTRACTJOINALGO_H_