#include "GroupByAndAggregate.h"#include "AggregateUtils.h"#include "Allocators/CudaAllocator.h"#include "CardinalityEstimator.h"#include "CodeGenerator.h"#include "Descriptors/QueryMemoryDescriptor.h"#include "ExpressionRange.h"#include "ExpressionRewrite.h"#include "GpuInitGroups.h"#include "InPlaceSort.h"#include "LLVMFunctionAttributesUtil.h"#include "MaxwellCodegenPatch.h"#include "OutputBufferInitialization.h"#include "TargetExprBuilder.h"#include "../CudaMgr/CudaMgr.h"#include "../Shared/checked_alloc.h"#include "../Utils/ChunkIter.h"#include "DataMgr/BufferMgr/BufferMgr.h"#include "Execute.h"#include "QueryTemplateGenerator.h"#include "RuntimeFunctions.h"#include "StreamingTopN.h"#include "TopKSort.h"#include "WindowContext.h"#include <llvm/Transforms/Utils/BasicBlockUtils.h>#include <numeric>#include <thread>
Include dependency graph for GroupByAndAggregate.cpp:Go to the source code of this file.
Namespaces | |
| anonymous_namespace{GroupByAndAggregate.cpp} | |
Macros | |
| #define | LL_CONTEXT executor_->cgen_state_->context_ |
| #define | LL_BUILDER executor_->cgen_state_->ir_builder_ |
| #define | LL_BOOL(v) executor_->cgen_state_->llBool(v) |
| #define | LL_INT(v) executor_->cgen_state_->llInt(v) |
| #define | LL_FP(v) executor_->cgen_state_->llFp(v) |
| #define | ROW_FUNC executor_->cgen_state_->row_func_ |
Functions | |
| int32_t | anonymous_namespace{GroupByAndAggregate.cpp}::get_agg_count (const std::vector< Analyzer::Expr *> &target_exprs) |
| bool | anonymous_namespace{GroupByAndAggregate.cpp}::expr_is_rowid (const Analyzer::Expr *expr, const Catalog_Namespace::Catalog &cat) |
| bool | anonymous_namespace{GroupByAndAggregate.cpp}::has_count_distinct (const RelAlgExecutionUnit &ra_exe_unit) |
| bool | anonymous_namespace{GroupByAndAggregate.cpp}::is_column_range_too_big_for_perfect_hash (const ColRangeInfo &col_range_info, const int64_t max_entry_count) |
| void | anonymous_namespace{GroupByAndAggregate.cpp}::add_transient_string_literals_for_expression (const Analyzer::Expr *expr, Executor *executor, std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner) |
| void | agg_count_distinct (int64_t *agg, const int64_t val) |
| void | agg_count_distinct_skip_val (int64_t *agg, const int64_t val, const int64_t skip_val) |
Variables | |
| bool | g_cluster {false} |
| bool | g_bigint_count {false} |
| int | g_hll_precision_bits {11} |
| size_t | g_leaf_count |
Macro Definition Documentation
◆ LL_BOOL
| #define LL_BOOL | ( | v | ) | executor_->cgen_state_->llBool(v) |
Definition at line 240 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegenOutputSlot().
◆ LL_BUILDER
| #define LL_BUILDER executor_->cgen_state_->ir_builder_ |
Definition at line 239 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegen(), GroupByAndAggregate::codegenAggArg(), GroupByAndAggregate::codegenAggCalls(), GroupByAndAggregate::codegenAggColumnPtr(), GroupByAndAggregate::codegenEstimator(), GroupByAndAggregate::codegenGroupBy(), GroupByAndAggregate::codegenMultiColumnBaselineHash(), GroupByAndAggregate::codegenMultiColumnPerfectHash(), GroupByAndAggregate::codegenOutputSlot(), GroupByAndAggregate::codegenWindowRowPointer(), GroupByAndAggregate::convertNullIfAny(), GroupByAndAggregate::DiamondCodegen::DiamondCodegen(), GroupByAndAggregate::getAdditionalLiteral(), and GroupByAndAggregate::DiamondCodegen::~DiamondCodegen().
◆ LL_CONTEXT
| #define LL_CONTEXT executor_->cgen_state_->context_ |
Definition at line 238 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegen(), GroupByAndAggregate::codegenAggArg(), GroupByAndAggregate::codegenAggCalls(), GroupByAndAggregate::codegenAggColumnPtr(), GroupByAndAggregate::codegenCountDistinct(), GroupByAndAggregate::codegenEstimator(), GroupByAndAggregate::codegenGroupBy(), GroupByAndAggregate::codegenMultiColumnBaselineHash(), GroupByAndAggregate::codegenMultiColumnPerfectHash(), GroupByAndAggregate::codegenPerfectHashFunction(), GroupByAndAggregate::codegenWindowRowPointer(), GroupByAndAggregate::DiamondCodegen::DiamondCodegen(), and GroupByAndAggregate::getAdditionalLiteral().
◆ LL_FP
| #define LL_FP | ( | v | ) | executor_->cgen_state_->llFp(v) |
Definition at line 242 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegenOutputSlot().
◆ LL_INT
| #define LL_INT | ( | v | ) | executor_->cgen_state_->llInt(v) |
Definition at line 241 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegen(), GroupByAndAggregate::codegenAggColumnPtr(), GroupByAndAggregate::codegenCountDistinct(), GroupByAndAggregate::codegenEstimator(), GroupByAndAggregate::codegenGroupBy(), GroupByAndAggregate::codegenMultiColumnBaselineHash(), GroupByAndAggregate::codegenMultiColumnPerfectHash(), GroupByAndAggregate::codegenOutputSlot(), GroupByAndAggregate::codegenPerfectHashFunction(), GroupByAndAggregate::codegenSingleColumnPerfectHash(), GroupByAndAggregate::codegenWindowRowPointer(), and GroupByAndAggregate::getAdditionalLiteral().
◆ ROW_FUNC
| #define ROW_FUNC executor_->cgen_state_->row_func_ |
Definition at line 243 of file GroupByAndAggregate.cpp.
Referenced by GroupByAndAggregate::codegen(), GroupByAndAggregate::codegenEstimator(), GroupByAndAggregate::codegenGroupBy(), GroupByAndAggregate::codegenMultiColumnBaselineHash(), GroupByAndAggregate::codegenOutputSlot(), GroupByAndAggregate::codegenWindowRowPointer(), GroupByAndAggregate::DiamondCodegen::DiamondCodegen(), and GroupByAndAggregate::getAdditionalLiteral().
Function Documentation
◆ agg_count_distinct()
| void agg_count_distinct | ( | int64_t * | agg, |
| const int64_t | val | ||
| ) |
Definition at line 1639 of file GroupByAndAggregate.cpp.
Referenced by agg_count_distinct_skip_val().
Here is the caller graph for this function:◆ agg_count_distinct_skip_val()
| void agg_count_distinct_skip_val | ( | int64_t * | agg, |
| const int64_t | val, | ||
| const int64_t | skip_val | ||
| ) |
Definition at line 1643 of file GroupByAndAggregate.cpp.
References agg_count_distinct().
Here is the call graph for this function:Variable Documentation
◆ g_bigint_count
| bool g_bigint_count {false} |
Definition at line 50 of file GroupByAndAggregate.cpp.
Referenced by QueryMemoryInitializer::allocateCountDistinctBuffers(), TargetExprCodegen::codegen(), GroupByAndAggregate::codegenCountDistinct(), ColSlotContext::ColSlotContext(), anonymous_namespace{RelAlgExecutor.cpp}::decide_approx_count_distinct_implementation(), Executor::executePlanWithoutGroupBy(), anonymous_namespace{Execute.cpp}::fill_entries_for_empty_input(), MapDProgramOptions::fillOptions(), get_agg_type(), get_col_byte_widths(), get_heap_key_slot_index(), Executor::getDeviceTypeForTargets(), RelAlgExecutor::getFilteredCountAll(), RelAlgExecutor::getFilterSelectivity(), GroupByAndAggregate::getKeylessInfo(), anonymous_namespace{GroupByAndAggregate.cpp}::has_count_distinct(), init_agg_val_vec(), QueryMemoryInitializer::initColumnarGroups(), GroupByAndAggregate::initCountDistinctDescriptors(), TargetExprCodegenBuilder::operator()(), QueryMemoryDescriptor::pick_target_compact_width(), Executor::reduceMultiDeviceResults(), Executor::resultsUnion(), and target_exprs_to_infos().
◆ g_cluster
| bool g_cluster {false} |
Definition at line 49 of file GroupByAndAggregate.cpp.
Referenced by QueryMemoryDescriptor::blocksShareMemory(), RelAlgDagBuilder::build(), QueryFragmentDescriptor::checkDeviceMemoryUsage(), JoinHashTable::checkHashJoinReplicationConstraint(), BaselineJoinHashTable::checkHashJoinReplicationConstraint(), GroupByAndAggregate::codegenAggCalls(), GroupByAndAggregate::codegenAggColumnPtr(), CodeGenerator::codegenCastFromString(), CodeGenerator::codegenQualifierCmp(), DBHandler::DBHandler(), anonymous_namespace{RelAlgExecutor.cpp}::decide_approx_count_distinct_implementation(), anonymous_namespace{RelAlgExecutor.cpp}::do_table_reordering(), TableArchiver::dumpTable(), Parser::CreateTableAsSelectStmt::execute(), RelAlgExecutor::executeRelAlgStep(), RelAlgExecutor::executeSort(), RelAlgExecutor::executeTableFunction(), anonymous_namespace{Execute.cpp}::fill_entries_for_empty_input(), get_count_distinct_sub_bitmap_count(), DBHandler::get_status(), RelAlgTranslator::getInIntegerSetExpr(), QueryMemoryDescriptor::isLogicalSizedColumnsAllowed(), DBHandler::load_table(), DBHandler::load_table_binary(), Parser::InsertIntoTableAsSelectStmt::populateData(), DBHandler::prepare_columnar_loader(), Executor::resetInterrupt(), TableArchiver::restoreTable(), DBHandler::sql_execute_impl(), use_speculative_top_n(), and anonymous_namespace{QueryMemoryDescriptor.cpp}::use_streaming_top_n().
◆ g_hll_precision_bits
| int g_hll_precision_bits {11} |
Definition at line 51 of file GroupByAndAggregate.cpp.
Referenced by anonymous_namespace{RelAlgExecutor.cpp}::decide_approx_count_distinct_implementation(), MapDProgramOptions::fillOptions(), hll_size_for_rate(), and GroupByAndAggregate::initCountDistinctDescriptors().
◆ g_leaf_count
| size_t g_leaf_count |
Definition at line 69 of file ParserNode.cpp.
Referenced by GroupByAndAggregate::getShardedTopBucket().
