main3.cpp

Go to the documentation of this file.

#include <ReducerFunctionalObjectSphinx.hpp>
#include <iostream>

int main(int argc, char** argv)
{
  HCE::reduce::ReducerFunctionalObjectSphinx reducerFunctionalObjectSphinx;
  
  std::string jsonReducingInputMessage = "";
  unsigned long long itemId = 3;
  int nodesCount = 2;
  
  //1 iteratuin
  reducerFunctionalObjectSphinx.accumulate(jsonReducingInputMessage, itemId);
  if (reducerFunctionalObjectSphinx.getErrCode() != HCE::reduce::OK){
    std::cout << "1."<<reducerFunctionalObjectSphinx.getErrMsg() << std::endl;
  }
  
  if (reducerFunctionalObjectSphinx.isCompleteTask(itemId, nodesCount) == true){
    Poco::SharedPtr<HCE::reduce_types::ReducingOutputMessage>reducingOutputMessage = reducerFunctionalObjectSphinx.reduce(itemId);
    std::cout << "reduce results\n";
    std::cout << reducingOutputMessage->getProcessingType() << std::endl;
    std::cout << reducingOutputMessage->getBody() << std::endl;
    std::cout << reducingOutputMessage->getProcessingErrorCode() << std::endl;
    std::cout << reducingOutputMessage->getProcessingErrorMsg() << std::endl;
    std::cout << reducingOutputMessage->getProcessingElapsedTime() << std::endl;
  }
  else{
    std::cout << "2." << reducerFunctionalObjectSphinx.getErrCode() << reducerFunctionalObjectSphinx.getErrMsg() << std::endl;
  }
  //end iteration
  
  return 0;
}