DefaultContainerScheduler.h

Go to the documentation of this file.

//
// Created by Nico on 13/05/2019.
//
 
#ifndef JODA_DEFAULTCONTAINERSCHEDULER_H
#define JODA_DEFAULTCONTAINERSCHEDULER_H
 
#include <joda/container/ContainerFlags.h>
#include <joda/container/JSONContainer.h>
#include <joda/misc/RJFwd.h>
#include <rapidjson/istreamwrapper.h>
 
namespace joda::docparsing {
template <bool meta>
class DefaultContainerScheduler {
 public:
  typedef short ContainerIdentifier;
 
  DefaultContainerScheduler(JsonContainerQueue::queue_t *queue,
                            size_t contSize = 0);
 
  ContainerIdentifier getContainerForDoc(const RJDocument &doc);
 
  ContainerIdentifier getContainerForDoc(std::string &raw);
 
  ContainerIdentifier getContainerForDoc(rapidjson::IStreamWrapper &stream);
 
  void scheduleDocument(ContainerIdentifier id,
                        std::unique_ptr<RJDocument> &&doc,
                        std::unique_ptr<IOrigin> &&origin, size_t size);
 
  std::unique_ptr<RJDocument> getNewDoc(ContainerIdentifier id);
 
  void finalize();
 
  virtual ~DefaultContainerScheduler() = default;
 
 private:
  JsonContainerQueue::queue_t *queue;
  size_t contSize;
 
  std::unique_ptr<JSONContainer> currentContainer;
  std::unique_ptr<JSONContainer> createContainer(size_t contSize) const;
};
}  // namespace joda::docparsing
 
#endif  // JODA_DEFAULTCONTAINERSCHEDULER_H