NCBI C++ ToolKit
Public Member Functions | Static Public Attributes | Private Attributes | List of all members
CCassandraFullscanRunner Class Reference

Search Toolkit Book for CCassandraFullscanRunner

#include <objtools/pubseq_gateway/impl/cassandra/fullscan/runner.hpp>

+ Collaboration diagram for CCassandraFullscanRunner:

Public Member Functions

 CCassandraFullscanRunner ()
 
 CCassandraFullscanRunner (const CCassandraFullscanRunner &)=delete
 
 CCassandraFullscanRunner (CCassandraFullscanRunner &&)=default
 
CCassandraFullscanRunneroperator= (const CCassandraFullscanRunner &)=delete
 
CCassandraFullscanRunneroperator= (CCassandraFullscanRunner &&)=default
 
CCassandraFullscanRunnerSetThreadCount (size_t value)
 
CCassandraFullscanRunnerSetConsistency (CassConsistency value)
 
CCassandraFullscanRunnerSetPageSize (unsigned int value)
 
CCassandraFullscanRunnerSetMaxActiveStatements (unsigned int value)
 
CCassandraFullscanRunnerSetConsumerFactory (TCassandraFullscanConsumerFactory consumer_factory)
 
CCassandraFullscanRunnerSetExecutionPlan (unique_ptr< ICassandraFullscanPlan > plan)
 
CCassandraFullscanRunnerSetMaxRetryCount (unsigned int max_retry_count)
 
CCassandraFullscanRunnerSetConsumerCreationPolicy (ECassandraFullscanConsumerPolicy policy)
 
bool Execute ()
 

Static Public Attributes

static const unsigned int kPageSizeDefault = 4096
 
static const unsigned int kMaxActiveStatementsDefault = 256
 
static const unsigned int kMaxRetryCountDefault = 5
 

Private Attributes

size_t m_ThreadCount {1}
 
TCassConsistency m_Consistency {CCassConsistency::kLocalQuorum}
 
unsigned int m_PageSize {kPageSizeDefault}
 
unsigned int m_MaxActiveStatements {kMaxActiveStatementsDefault}
 
TCassandraFullscanConsumerFactory m_ConsumerFactory {nullptr}
 
mutex m_ConsumerFactoryMutex
 
unique_ptr< ICassandraFullscanPlanm_ExecutionPlan
 
unsigned int m_MaxRetryCount {kMaxRetryCountDefault}
 
ECassandraFullscanConsumerPolicy m_ConsumerCreationPolicy {ECassandraFullscanConsumerPolicy::eOnePerThread}
 

Detailed Description

Definition at line 47 of file runner.hpp.

Constructor & Destructor Documentation

◆ CCassandraFullscanRunner() [1/3]

CCassandraFullscanRunner::CCassandraFullscanRunner ( )
default

◆ CCassandraFullscanRunner() [2/3]

CCassandraFullscanRunner::CCassandraFullscanRunner ( const CCassandraFullscanRunner )
delete

◆ CCassandraFullscanRunner() [3/3]

CCassandraFullscanRunner::CCassandraFullscanRunner ( CCassandraFullscanRunner &&  )
default

Member Function Documentation

◆ Execute()

bool CCassandraFullscanRunner::Execute ( void  )

◆ operator=() [1/2]

CCassandraFullscanRunner& CCassandraFullscanRunner::operator= ( CCassandraFullscanRunner &&  )
default

◆ operator=() [2/2]

CCassandraFullscanRunner& CCassandraFullscanRunner::operator= ( const CCassandraFullscanRunner )
delete

◆ SetConsistency()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetConsistency ( CassConsistency  value)

Definition at line 56 of file runner.cpp.

References m_Consistency, and rapidjson::value.

◆ SetConsumerCreationPolicy()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetConsumerCreationPolicy ( ECassandraFullscanConsumerPolicy  policy)

Definition at line 86 of file runner.cpp.

References m_ConsumerCreationPolicy.

◆ SetConsumerFactory()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetConsumerFactory ( TCassandraFullscanConsumerFactory  consumer_factory)

Definition at line 78 of file runner.cpp.

References m_ConsumerFactory.

◆ SetExecutionPlan()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetExecutionPlan ( unique_ptr< ICassandraFullscanPlan plan)

Definition at line 92 of file runner.cpp.

References m_ExecutionPlan, and NCBI_THROW.

◆ SetMaxActiveStatements()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetMaxActiveStatements ( unsigned int  value)

Definition at line 70 of file runner.cpp.

References m_MaxActiveStatements, and rapidjson::value.

◆ SetMaxRetryCount()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetMaxRetryCount ( unsigned int  max_retry_count)

Definition at line 105 of file runner.cpp.

References m_MaxRetryCount.

◆ SetPageSize()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetPageSize ( unsigned int  value)

Definition at line 62 of file runner.cpp.

References m_PageSize, and rapidjson::value.

◆ SetThreadCount()

CCassandraFullscanRunner & CCassandraFullscanRunner::SetThreadCount ( size_t  value)

Definition at line 50 of file runner.cpp.

References m_ThreadCount, and rapidjson::value.

Member Data Documentation

◆ kMaxActiveStatementsDefault

const unsigned int CCassandraFullscanRunner::kMaxActiveStatementsDefault = 256
static

Definition at line 51 of file runner.hpp.

◆ kMaxRetryCountDefault

const unsigned int CCassandraFullscanRunner::kMaxRetryCountDefault = 5
static

Definition at line 52 of file runner.hpp.

◆ kPageSizeDefault

const unsigned int CCassandraFullscanRunner::kPageSizeDefault = 4096
static

Definition at line 50 of file runner.hpp.

◆ m_Consistency

TCassConsistency CCassandraFullscanRunner::m_Consistency {CCassConsistency::kLocalQuorum}
private

Definition at line 72 of file runner.hpp.

Referenced by Execute(), and SetConsistency().

◆ m_ConsumerCreationPolicy

ECassandraFullscanConsumerPolicy CCassandraFullscanRunner::m_ConsumerCreationPolicy {ECassandraFullscanConsumerPolicy::eOnePerThread}
private

Definition at line 79 of file runner.hpp.

Referenced by Execute(), and SetConsumerCreationPolicy().

◆ m_ConsumerFactory

TCassandraFullscanConsumerFactory CCassandraFullscanRunner::m_ConsumerFactory {nullptr}
private

Definition at line 75 of file runner.hpp.

Referenced by Execute(), and SetConsumerFactory().

◆ m_ConsumerFactoryMutex

mutex CCassandraFullscanRunner::m_ConsumerFactoryMutex
private

Definition at line 76 of file runner.hpp.

Referenced by Execute().

◆ m_ExecutionPlan

unique_ptr<ICassandraFullscanPlan> CCassandraFullscanRunner::m_ExecutionPlan
private

Definition at line 77 of file runner.hpp.

Referenced by Execute(), and SetExecutionPlan().

◆ m_MaxActiveStatements

unsigned int CCassandraFullscanRunner::m_MaxActiveStatements {kMaxActiveStatementsDefault}
private

Definition at line 74 of file runner.hpp.

Referenced by Execute(), and SetMaxActiveStatements().

◆ m_MaxRetryCount

unsigned int CCassandraFullscanRunner::m_MaxRetryCount {kMaxRetryCountDefault}
private

Definition at line 78 of file runner.hpp.

Referenced by Execute(), and SetMaxRetryCount().

◆ m_PageSize

unsigned int CCassandraFullscanRunner::m_PageSize {kPageSizeDefault}
private

Definition at line 73 of file runner.hpp.

Referenced by Execute(), and SetPageSize().

◆ m_ThreadCount

size_t CCassandraFullscanRunner::m_ThreadCount {1}
private

Definition at line 71 of file runner.hpp.

Referenced by Execute(), and SetThreadCount().


The documentation for this class was generated from the following files:
Modified on Sat Jul 13 13:40:16 2024 by modify_doxy.py rev. 669887