Column-oriented GPU-accelerated Database Management System
CoGaDB
|
#include <groupby_operator.hpp>
Public Types | |
typedef hype::queryprocessing::OperatorMapper_Helper_Template < TablePtr >::TypedOperatorPtr | TypedOperatorPtr |
Public Member Functions | |
CPU_Groupby_Operator (const hype::SchedulingDecision &sched_dec, TypedOperatorPtr child, const std::list< std::string > &grouping_columns, const std::list< ColumnAggregation > &aggregation_functions, MaterializationStatus mat_stat=MATERIALIZE) | |
virtual bool | execute () |
virtual | ~CPU_Groupby_Operator () |
Private Attributes | |
std::list< std::string > | grouping_columns_ |
std::list< ColumnAggregation > | aggregation_functions_ |
MaterializationStatus | mat_stat_ |
typedef hype::queryprocessing::OperatorMapper_Helper_Template<TablePtr>::TypedOperatorPtr CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::TypedOperatorPtr |
Reimplemented from hype::queryprocessing::UnaryOperator< TablePtr, TablePtr >.
CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::CPU_Groupby_Operator | ( | const hype::SchedulingDecision & | sched_dec, |
TypedOperatorPtr | child, | ||
const std::list< std::string > & | grouping_columns, | ||
const std::list< ColumnAggregation > & | aggregation_functions, | ||
MaterializationStatus | mat_stat = MATERIALIZE |
||
) | [inline] |
virtual CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::~CPU_Groupby_Operator | ( | ) | [inline, virtual] |
virtual bool CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::execute | ( | ) | [inline, virtual] |
Implements hype::queryprocessing::Operator.
References aggregation_functions_, CoGaDB::CPU, hype::queryprocessing::UnaryOperator< TablePtr, TablePtr >::getInputData(), CoGaDB::BaseTable::groupby(), grouping_columns_, hype::queryprocessing::TypedOperator< TablePtr >::result_, and hype::queryprocessing::TypedOperator< TablePtr >::setResultSize().
std::list<ColumnAggregation> CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::aggregation_functions_ [private] |
Referenced by execute().
std::list<std::string> CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::grouping_columns_ [private] |
Referenced by execute().
MaterializationStatus CoGaDB::query_processing::physical_operator::CPU_Groupby_Operator::mat_stat_ [private] |