HCE project C++ developers source code library  1.1.1
HCE project developer library
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
DRCETaskReducersManager.hpp
Go to the documentation of this file.
1 
14 #ifndef DRCETASKREDUCERSMANAGER_HPP_
15 #define DRCETASKREDUCERSMANAGER_HPP_
16 
18 #include "Exceptions.hpp"
19 #include "DRCEResultData.hpp"
20 #include <map>
21 #include <Poco/SharedPtr.h>
22 
24 
25 namespace HCE {
26 namespace drce{
27 namespace reduce_task {
28 
30 public:
31  virtual ~DRCETaskReducersManager();
32 
34  bool isReducerExist(unsigned long long reduceTaskId);
35  void createReducer(unsigned long long reduceTaskId);
36  void addDataInReducer(unsigned long long reduceTaskId, const std::string& json);
37  std::string runReduceTaskForTaskId(unsigned long long reduceTaskId);
38  void deleteReducerBy(unsigned long long reduceTaskId);
39 
40 private:
41  std::map< unsigned long long, Poco::SharedPtr< DRCEResultData > > taskReduceResults_;
42 };
43 
44 }
45 }
46 }
47 
48 #endif