FileDataLoader.h

Go to the documentation of this file.

 
//
// Created by tony on 29/12/22.
//
 
#ifndef _INCLUDE_TESTBENCH_FileDataLoader_H_
#define _INCLUDE_TESTBENCH_FileDataLoader_H_
#include <Utils/ConfigMap.hpp>
#include <Common/Tuples.h>
#include <assert.h>
#include <TestBench/AbstractDataLoader.h>
using namespace INTELLI;
 
namespace OoOJoin {
 
class FileDataLoader : public AbstractDataLoader {
 protected:
 
  void spilt(const std::string s, const std::string &c, vector<std::string> &v) {
    std::string::size_type pos1, pos2;
    pos2 = s.find(c);
    pos1 = 0;
    while (std::string::npos != pos2) {
      v.push_back(s.substr(pos1, pos2 - pos1));
 
      pos1 = pos2 + c.size();
      pos2 = s.find(c, pos1);
    }
    if (pos1 != s.length())
      v.push_back(s.substr(pos1));
  }
  std::vector<TrackTuplePtr> loadDataFromCsv(std::string fname,
                                             std::string separator = ",",
                                             std::string newLine = "\n");
 public:
  ConfigMapPtr cfgGlobal;
  vector<TrackTuplePtr> sTuple, rTuple;
  FileDataLoader() {}
  ~FileDataLoader() {}
  virtual bool setConfig(ConfigMapPtr cfg);
 
  virtual bool setModConfig(ConfigMapPtr cfg) {
    assert(cfg);
    return true;
  }
  virtual vector<TrackTuplePtr> getTupleVectorS();
 
  virtual vector<TrackTuplePtr> getTupleVectorR();
 
};
 
typedef std::shared_ptr<class FileDataLoader> FileDataLoaderPtr;
#define newFileDataLoader std::make_shared<OoOJoin::FileDataLoader>
}
#endif //INTELLISTREAM_INCLUDE_TESTBENCH_FileDataLoader_H_