QueryPlan.h

Go to the documentation of this file.

//
// Created by Nico Schäfer on 4/25/17.
//
 
#ifndef JODA_QUERYPLAN_H
#define JODA_QUERYPLAN_H
 
#include <joda/misc/Benchmark.h>
#include <joda/parser/ReaderParser.h>
#include <joda/query/Query.h>
#include <joda/query/aggregation/IAggregator.h>
#include <joda/storage/JSONStorage.h>
struct ExecutionStats {
  size_t parsedDocs;
  size_t parsedConts;
  size_t numConts;
  size_t evaluatedConts;
};
 
class QueryPlan {
 public:
  QueryPlan(const std::shared_ptr<joda::query::Query> &q);
 
  unsigned long executeQuery(Benchmark *bench = nullptr);
 
  ExecutionStats getStats() const;
 
  bool hasToParse() const;
 
 protected:
  unsigned long resultID = 0;
  unsigned long maxThreads = 0;
  bool skip = false;
 
  void addGenericBenchmarkInformation(Benchmark *bench = nullptr) const;
  std::shared_ptr<JSONStorage> load;
  std::shared_ptr<joda::query::Query> q;
  std::unique_ptr<JSONContainer> aggregate(
      std::shared_ptr<joda::query::Query> &q,
      joda::query::AggregatorQueue::queue_t *queue, Benchmark *benchmark);
  std::unique_ptr<JsonContainerRefQueue::queue_t> loadQueue;
  std::unique_ptr<JsonContainerQueue::queue_t> storeQueue;
  std::unique_ptr<joda::query::AggregatorQueue::queue_t> aggregatorQueue;
  joda::docparsing::ReaderParser parser;
};
 
#endif  // JODA_QUERYPLAN_H