OmniSciDB
85c2d10cdc
|
#include "QueryEngine/JoinHashTable/HashJoin.h"
#include "QueryEngine/ColumnFetcher.h"
#include "QueryEngine/EquiJoinCondition.h"
#include "QueryEngine/Execute.h"
#include "QueryEngine/JoinHashTable/BaselineJoinHashTable.h"
#include "QueryEngine/JoinHashTable/OverlapsJoinHashTable.h"
#include "QueryEngine/JoinHashTable/PerfectJoinHashTable.h"
#include "QueryEngine/RangeTableIndexVisitor.h"
#include "QueryEngine/RuntimeFunctions.h"
#include "QueryEngine/ScalarExprVisitor.h"
Go to the source code of this file.
Classes | |
class | AllColumnVarsVisitor |
Namespaces | |
anonymous_namespace{HashJoin.cpp} | |
Variables | |
bool | g_enable_overlaps_hashjoin |
size_t get_shard_count | ( | const Analyzer::BinOper * | join_condition, |
const Executor * | executor | ||
) |
Definition at line 553 of file HashJoin.cpp.
References anonymous_namespace{HashJoin.cpp}::get_cols(), and get_shard_count().
Referenced by get_shard_count(), BaselineJoinHashTable::getShardCountForCondition(), PerfectJoinHashTable::reify(), PerfectJoinHashTable::shardCount(), and Executor::skipFragmentPair().
std::shared_ptr<Analyzer::ColumnVar> getSyntheticColumnVar | ( | std::string_view | table, |
std::string_view | column, | ||
int | rte_idx, | ||
Executor * | executor | ||
) |
Definition at line 356 of file HashJoin.cpp.
References CHECK, kLINESTRING, kMULTIPOLYGON, kPOINT, and kPOLYGON.
Referenced by HashJoin::getSyntheticInstance().
std::vector<InputTableInfo> getSyntheticInputTableInfo | ( | std::set< const Analyzer::ColumnVar * > | cvs, |
Executor * | executor | ||
) |
Definition at line 441 of file HashJoin.cpp.
Referenced by HashJoin::getSyntheticInstance().
InnerOuter normalize_column_pair | ( | const Analyzer::Expr * | lhs, |
const Analyzer::Expr * | rhs, | ||
const Catalog_Namespace::Catalog & | cat, | ||
const TemporaryTables * | temporary_tables, | ||
const bool | is_overlaps_join | ||
) |
Definition at line 570 of file HashJoin.cpp.
References cat(), get_column_descriptor_maybe(), get_column_type(), Analyzer::Expr::get_type_info(), is_constructed_point(), kCAST, kENCODING_DICT, kPOINT, gpu_enabled::swap(), and ScalarExprVisitor< T >::visit().
Referenced by anonymous_namespace{PerfectJoinHashTable.cpp}::get_cols(), anonymous_namespace{HashJoin.cpp}::get_cols(), and normalize_column_pairs().
std::vector<InnerOuter> normalize_column_pairs | ( | const Analyzer::BinOper * | condition, |
const Catalog_Namespace::Catalog & | cat, | ||
const TemporaryTables * | temporary_tables | ||
) |
Definition at line 705 of file HashJoin.cpp.
References cat(), CHECK, CHECK_EQ, Analyzer::BinOper::get_left_operand(), Analyzer::BinOper::get_right_operand(), i, Analyzer::BinOper::is_overlaps_oper(), normalize_column_pair(), and run_benchmark_import::result.
Referenced by anonymous_namespace{FromTableReordering.cpp}::get_join_qual_cost(), BaselineJoinHashTable::getInstance(), OverlapsJoinHashTable::getInstance(), and Executor::skipFragmentPair().
std::ostream& operator<< | ( | std::ostream & | os, |
const DecodedJoinHashBufferEntry & | e | ||
) |
Definition at line 122 of file HashJoin.cpp.
References generate_TableFunctionsFactory_init::k, DecodedJoinHashBufferEntry::key, and DecodedJoinHashBufferEntry::payload.
std::ostream& operator<< | ( | std::ostream & | os, |
const DecodedJoinHashBufferSet & | s | ||
) |
Definition at line 148 of file HashJoin.cpp.
void setupSyntheticCaching | ( | std::set< const Analyzer::ColumnVar * > | cvs, |
Executor * | executor | ||
) |
Definition at line 427 of file HashJoin.cpp.
Referenced by HashJoin::getSyntheticInstance().
bool g_enable_overlaps_hashjoin |
Definition at line 96 of file Execute.cpp.