TestBench.h

Go to the documentation of this file.

 
//
// Created by tony on 23/11/22.
//
 
#ifndef INTELLISTREAM_INCLUDE_TESTBENCH_TESTBENCH_H_
#define INTELLISTREAM_INCLUDE_TESTBENCH_TESTBENCH_H_
#include <Common/Window.h>
#include <Operator/AbstractOperator.h>
#include <Utils/IntelliLog.h>
#include <string>
#include <fstream>
#include <iostream>
#include <sstream>
#include <TestBench/DataLoaderTable.h>
using namespace INTELLI;
#define TB_INFO INTELLI_INFO
#define TB_ERROR INTELLI_ERROR
#define TB_WARNNING INTELLI_WARNING
namespace OoOJoin {
 
class TestBench {
 protected:
  void inOrderSort(std::vector<TrackTuplePtr> &arr);
  void OoOSort(std::vector<TrackTuplePtr> &arr);
  void inlineTest(void);
  void forceInOrder(std::vector<TrackTuplePtr> &arr);
  tsType timeStep = 1;
 
 public:
  std::vector<TrackTuplePtr> rTuple;
  std::vector<TrackTuplePtr> sTuple;
  AbstractOperatorPtr testOp = nullptr;
  ConfigMapPtr opConfig;
  size_t AQPResult = 0;
  TestBench() {}
  ~TestBench() {}
 
  void setDataLoader(std::string tag, ConfigMapPtr globalCfg);
  size_t sizeOfS() {
    return sTuple.size();
  }
  size_t sizeOfR() {
    return rTuple.size();
  }
  void setDataSet(std::vector<TrackTuplePtr> _r, std::vector<TrackTuplePtr> _s);
  bool setOperator(AbstractOperatorPtr op, ConfigMapPtr cfg);
  size_t inOrderTest(bool additionalSort);
  size_t OoOTest(bool additionalSort);
  void logRTuples(bool skipZero = false);
  bool saveRTuplesToFile(string fname, bool skipZero = false);
  bool saveSTuplesToFile(string fname, bool skipZero = false);
  double getAvgLatency();
  double getThroughput();
  double getLatencyPercentage(double fraction);
  ConfigMapPtr getTimeBreakDown();
};
}
#endif //INTELLISTREAM_INCLUDE_TESTBENCH_TESTBENCH_H_