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 Member List

This is the complete list of members for HCE::reduce::ReducingHandler, including all inherited members.

accumulateReducingData(unsigned long long itemId, Poco::SharedPtr< reduce_types::ReducingInputMessage > &reducingInputMessage)HCE::reduce::ReducingHandler
cleanupExpiredTasksByTTL(unsigned int maxRemoveTasks=1, unsigned int ttl=USE_TASK_TTL_VALUE)HCE::reduce::ReducingHandler
cleanupExpiredTasksByTTLQueue(unsigned int maxRemoveItems, unsigned int minTerminateTime)HCE::reduce::ReducingHandler
deleteReducingTaskBy(unsigned long long itemId)HCE::reduce::ReducingHandler
getAccumulateReducingPartsNumberBy(unsigned long long itemId)HCE::reduce::ReducingHandler
getExceededTTLTasks(unsigned int maxTaskNumber, std::vector< unsigned long long > &exceededTTLTasks, unsigned int ttl=USE_TASK_TTL_VALUE) const HCE::reduce::ReducingHandler
getTasksNumber()HCE::reduce::ReducingHandler
isTaskExpired(unsigned long long taskId, unsigned int ttl=USE_TASK_TTL_VALUE)HCE::reduce::ReducingHandler
isTaskTerminatedByTTL(unsigned long long taskId) const HCE::reduce::ReducingHandler
makeReducing(unsigned long long itemId)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)HCE::reduce::ReducingHandler
~ReducingHandler()HCE::reduce::ReducingHandlervirtual