SphinxReduceJob.hpp

Go to the documentation of this file.

#ifndef SPHINXREDUCEJOB_HPP_
#define SPHINXREDUCEJOB_HPP_

#include "ReduceTaskCore.hpp"
#include "SphinxReduceDataStorage.hpp"
#include "SphinxReduceTask.hpp"
#include "SphinxReduceResult.hpp"

namespace HCE{
namespace sphinx{
namespace reduce_task
{

class SphinxReduceJob: public HCE::reduce::core::ReduceJobIf{
public:
   SphinxReduceJob(Poco::SharedPtr<SphinxReduceDataStorage>& sphinxReduceDataStorage,
                   Poco::SharedPtr<SphinxReduceTask>& sphinxReduceTask,
                   Poco::SharedPtr<SphinxReduceResult>& sphinxReduceResult);
   ~SphinxReduceJob();

   Poco::SharedPtr<HCE::reduce::core::IterableIf> getDataStorage() const;
   Poco::SharedPtr<HCE::reduce::core::ReduceResultIf> getReduceResult() const;
   Poco::SharedPtr<HCE::reduce::core::ReduceTaskIf> getReduceTask() const;

private:
   SphinxReduceJob();
   Poco::SharedPtr<SphinxReduceDataStorage> _sphinxReduceDataStorage;
   Poco::SharedPtr<SphinxReduceTask> _sphinxReduceTask;
   Poco::SharedPtr<SphinxReduceResult> _sphinxReduceResult;
};

}
}
}

#endif