JoinAlgoTable.h

 
//
// Created by tony on 11/03/22.
//
 
#ifndef _JOINALGO_JOINALGOTABLE_H_
#define _JOINALGO_JOINALGOTABLE_H_
#include <JoinAlgos/AbstractJoinAlgo.h>
#include <JoinAlgos/NestedLoopJoin.h>
#include <JoinAlgos/NPJ/NPJ.h>
#include <map>
namespace OoOJoin {
class JoinAlgoTable {
 protected:
  std::vector<AbstractJoinAlgoPtr> algos;
  std::map<std::string, AbstractJoinAlgoPtr> algoMap;
 public:
  JoinAlgoTable();
  ~JoinAlgoTable() {
 
  }
  AbstractJoinAlgoPtr findAlgo(size_t idx) {
    if (idx < algos.size()) {
      return algos[idx];
    }
    return algos[0];
  }
  AbstractJoinAlgoPtr findAlgo(std::string name) {
    /*size_t maxIdx = algos.size();
    for (size_t i = 0; i < maxIdx; i++) {
      if (algos[i]->getAlgoName() == name) {
        return algos[i];
      }
    }*/
    if (algoMap.count(name)) {
      return algoMap[name];
    }
    return algos[0];
  }
  size_t registerNewAlgo(AbstractJoinAlgoPtr anew) {
    algos.push_back(anew);
    return algos.size() - 1;
  }
};
typedef std::shared_ptr<JoinAlgoTable> JoinAlgoTablePtr;
#define  newJoinAlgoTable std::make_shared<JoinAlgoTable>
typedef enum {
  JOINALGO_NULL = 0,
  JOINALGO_NESTEDLOOP = 1,
  JOINALGO_NPJ = 2,
  JOINALGO_NPJ_SINGLE = 3,
} join_algo_index_t;
}
#endif //ALIANCEDB_INCLUDE_JOINALGO_JOINALGOTABLE_H_