hce-node application  1.4.3
HCE Hierarchical Cluster Engine node application
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
HCE::reduce::ReducingHandler Class Reference

#include <ReducingHandler.hpp>

Public Member Functions

 ReducingHandler (const Poco::SharedPtr< ReducingPartsCountersStorageIf > &reducingPartsCountersStorage, const Poco::SharedPtr< ReduceAdditionsStorageIf > &reduceAdditionsStorage, const Poco::SharedPtr< TaskReducersManagerFactoryIf > &taskReducersManagerFactory, const Poco::SharedPtr< ReducingOutputMessageBuilderIf > &reducingOutputMessageBuilder, const Poco::SharedPtr< SupportNotifierIf > &supportNotifier)
virtual ~ReducingHandler ()
void accumulateReducingData (unsigned long long itemId, Poco::SharedPtr< reduce_types::ReducingInputMessage > &reducingInputMessage)
Poco::SharedPtr
< reduce_types::ReducingOutputMessage
makeReducing (unsigned long long itemId)
void deleteReducingTaskBy (unsigned long long itemId)
int getAccumulateReducingPartsNumberBy (unsigned long long itemId)
unsigned int getTasksNumber ()
bool isTaskTerminatedByTTL (unsigned long long taskId) const
bool isTaskExpired (unsigned long long taskId, unsigned int ttl=USE_TASK_TTL_VALUE)
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) const

Detailed Description

Definition at line 30 of file ReducingHandler.hpp.

Constructor & Destructor Documentation

HCE::reduce::ReducingHandler::ReducingHandler ( const Poco::SharedPtr< ReducingPartsCountersStorageIf > &  reducingPartsCountersStorage,
const Poco::SharedPtr< ReduceAdditionsStorageIf > &  reduceAdditionsStorage,
const Poco::SharedPtr< TaskReducersManagerFactoryIf > &  taskReducersManagerFactory,
const Poco::SharedPtr< ReducingOutputMessageBuilderIf > &  reducingOutputMessageBuilder,
const Poco::SharedPtr< SupportNotifierIf > &  supportNotifier 
)

Definition at line 6 of file ReducingHandler.cpp.

HCE::reduce::ReducingHandler::~ReducingHandler ( )
virtual

Definition at line 20 of file ReducingHandler.cpp.

Member Function Documentation

void HCE::reduce::ReducingHandler::accumulateReducingData ( unsigned long long  itemId,
Poco::SharedPtr< reduce_types::ReducingInputMessage > &  reducingInputMessage 
)

Definition at line 22 of file ReducingHandler.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 93 of file ReducingHandler.cpp.

Here is the call graph for this function:

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

Definition at line 99 of file ReducingHandler.cpp.

Here is the call graph for this function:

void HCE::reduce::ReducingHandler::deleteReducingTaskBy ( unsigned long long  itemId)

Definition at line 61 of file ReducingHandler.cpp.

Here is the caller graph for this function:

int HCE::reduce::ReducingHandler::getAccumulateReducingPartsNumberBy ( unsigned long long  itemId)

Definition at line 73 of file ReducingHandler.cpp.

Here is the caller graph for this function:

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

Definition at line 105 of file ReducingHandler.cpp.

Here is the call graph for this function:

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

Definition at line 78 of file ReducingHandler.cpp.

bool HCE::reduce::ReducingHandler::isTaskExpired ( unsigned long long  taskId,
unsigned int  ttl = USE_TASK_TTL_VALUE 
)

Definition at line 88 of file ReducingHandler.cpp.

Here is the call graph for this function:

bool HCE::reduce::ReducingHandler::isTaskTerminatedByTTL ( unsigned long long  taskId) const

Definition at line 83 of file ReducingHandler.cpp.

Here is the call graph for this function:

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

Definition at line 45 of file ReducingHandler.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:


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