ReduceTaskCore.hpp

Go to the documentation of this file.

#ifndef REDUCE_TASK_CORE_H
#define REDUCE_TASK_CORE_H

#include <Poco/SharedPtr.h>
#include <string>

namespace HCE{
namespace reduce{
namespace core{

class IterableIf{
public:
  virtual ~IterableIf(){}
  virtual bool hasNext() = 0;
  virtual void reset() = 0;
  virtual void getNext(std::string &key, std::string &value) = 0;
};


class StorableIf{
public:
  virtual ~StorableIf(){}
  virtual void addKeyValue(const std::string &key, const std::string &value) = 0;
};


class ReduceResultIf: public virtual IterableIf, public virtual StorableIf{
public:
  virtual ~ReduceResultIf(){}
};


class ReduceTaskIf: public virtual StorableIf{
public:
  virtual ~ReduceTaskIf(){}
  virtual void fillReduceResult(Poco::SharedPtr<ReduceResultIf> reduceResult) = 0;
};


class ReduceJobIf{
public:
  virtual ~ReduceJobIf(){}
  virtual Poco::SharedPtr<IterableIf> getDataStorage() const = 0;
  virtual Poco::SharedPtr<ReduceResultIf> getReduceResult() const = 0;
  virtual Poco::SharedPtr<ReduceTaskIf> getReduceTask() const = 0;
};


class ScheduleStrategyIf
{
public:
  virtual ~ScheduleStrategyIf(){}
  virtual void executeJob(const Poco::SharedPtr<ReduceJobIf> &reduceJob) = 0;
};

}
}
}

#endif