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
Public Member Functions | List of all members
HCE::reduce::ReducerFunctionalObject Class Reference

#include <ReducerFunctionalObject.hpp>

Public Member Functions

 ReducerFunctionalObject ()
 ~ReducerFunctionalObject ()
void accumulate (std::string &jsonReducingInputMessage, unsigned long long itemId)
bool isCompleteTask (unsigned long long itemId, int nodesCount, unsigned int ttl=USE_TASK_TTL_VALUE)
Poco::SharedPtr
< HCE::reduce_types::ReducingOutputMessage > 		reduce (unsigned long long itemId)
unsigned int getTasksNumber ()
int getErrCode () const
std::string getErrMsg () const
int cleanupExpiredTasksByTTL (unsigned int maxRemoveTasks=1, unsigned int ttl=USE_TASK_TTL_VALUE)
unsigned int cleanupExpiredTasksByTTLQueue (unsigned int maxRemoveItems, unsigned int minTerminateTime)
void getExceededTTLTasks (unsigned int maxTaskNumber, std::vector< unsigned long long > &exceededTTLTasks, unsigned int ttl=USE_TASK_TTL_VALUE)
int getRejectedMessages () const

Detailed Description

Definition at line 30 of file ReducerFunctionalObject.hpp.

Constructor & Destructor Documentation

HCE::reduce::ReducerFunctionalObject::ReducerFunctionalObject ( )

Definition at line 6 of file ReducerFunctionalObject.cpp.

Here is the call graph for this function:

HCE::reduce::ReducerFunctionalObject::~ReducerFunctionalObject ( )

Definition at line 14 of file ReducerFunctionalObject.cpp.

Member Function Documentation

void HCE::reduce::ReducerFunctionalObject::accumulate ( std::string &  jsonReducingInputMessage,
unsigned long long  itemId 
)

Definition at line 16 of file ReducerFunctionalObject.cpp.

int HCE::reduce::ReducerFunctionalObject::cleanupExpiredTasksByTTL ( unsigned int  maxRemoveTasks = 1,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)

Definition at line 80 of file ReducerFunctionalObject.cpp.

unsigned int HCE::reduce::ReducerFunctionalObject::cleanupExpiredTasksByTTLQueue ( unsigned int  maxRemoveItems,
unsigned int  minTerminateTime 
)

Definition at line 86 of file ReducerFunctionalObject.cpp.

int HCE::reduce::ReducerFunctionalObject::getErrCode ( ) const

Definition at line 70 of file ReducerFunctionalObject.cpp.

std::string HCE::reduce::ReducerFunctionalObject::getErrMsg ( ) const

Definition at line 75 of file ReducerFunctionalObject.cpp.

void HCE::reduce::ReducerFunctionalObject::getExceededTTLTasks ( unsigned int  maxTaskNumber,
std::vector< unsigned long long > &  exceededTTLTasks,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)

Definition at line 93 of file ReducerFunctionalObject.cpp.

int HCE::reduce::ReducerFunctionalObject::getRejectedMessages ( ) const

Definition at line 100 of file ReducerFunctionalObject.cpp.

unsigned int HCE::reduce::ReducerFunctionalObject::getTasksNumber ( )

Definition at line 65 of file ReducerFunctionalObject.cpp.

bool HCE::reduce::ReducerFunctionalObject::isCompleteTask ( unsigned long long  itemId,
int  nodesCount,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)

Definition at line 40 of file ReducerFunctionalObject.cpp.

Poco::SharedPtr< HCE::reduce_types::ReducingOutputMessage > HCE::reduce::ReducerFunctionalObject::reduce ( unsigned long long  itemId)

Definition at line 56 of file ReducerFunctionalObject.cpp.

The documentation for this class was generated from the following files: