OperatorTable.h

Go to the documentation of this file.

 
//
// Created by tony on 06/12/22.
//
 
#ifndef INTELLISTREAM_INCLUDE_OPERATOR_OPERATORTABLE_H_
#define INTELLISTREAM_INCLUDE_OPERATOR_OPERATORTABLE_H_
#include <Operator/IAWJOperator.h>
#include <Operator/MeanAQPIAWJOperator.h>
#include <Operator/IMAIAWJOperator.h>
#include <map>
namespace OoOJoin {
class OperatorTable {
 protected:
  std::map<std::string, AbstractOperatorPtr> operatorMap;
 public:
  OperatorTable();
  ~OperatorTable() {
  }
  void registerNewOperator(AbstractOperatorPtr onew, std::string tag) {
    operatorMap[tag] = onew;
  }
  AbstractOperatorPtr findOperator(std::string name) {
    if (operatorMap.count(name)) {
      return operatorMap[name];
    }
    return nullptr;
  }
};
typedef std::shared_ptr<class OperatorTable> OperatorTablePtr;
#define newOperatorTable std::make_shared<OoOJoin::OperatorTable>
} // OoOJoin
 
#endif //INTELLISTREAM_INCLUDE_OPERATOR_OPERATORTABLE_H_