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.

Here is the caller graph for this function:

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

Definition at line 82 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

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

Definition at line 88 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

int HCE::reduce::ReducerFunctionalObject::getErrCode

(

)

const

Definition at line 72 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

std::string HCE::reduce::ReducerFunctionalObject::getErrMsg

(

)

const

Definition at line 77 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

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

Definition at line 95 of file ReducerFunctionalObject.cpp.

int HCE::reduce::ReducerFunctionalObject::getRejectedMessages

(

)

const

Definition at line 103 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

unsigned int HCE::reduce::ReducerFunctionalObject::getTasksNumber

(

)

Definition at line 66 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

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

Definition at line 41 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

Poco::SharedPtr< HCE::reduce_types::ReducingOutputMessage > HCE::reduce::ReducerFunctionalObject::reduce

(

unsigned long long

itemId

)

Definition at line 57 of file ReducerFunctionalObject.cpp.

Here is the caller graph for this function:

---

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

• sources/utils/reduceHandler/src/ReducerFunctionalObject.hpp
• sources/utils/reduceHandler/src/ReducerFunctionalObject.cpp