BaselineJoinHashTable.cpp File Reference

#include "QueryEngine/JoinHashTable/BaselineJoinHashTable.h"
#include <future>
#include "DataMgr/Allocators/CudaAllocator.h"
#include "QueryEngine/CodeGenerator.h"
#include "QueryEngine/ColumnFetcher.h"
#include "QueryEngine/Execute.h"
#include "QueryEngine/ExpressionRewrite.h"
#include "QueryEngine/JoinHashTable/BaselineHashTable.h"
#include "QueryEngine/JoinHashTable/Builders/BaselineHashTableBuilder.h"
#include "QueryEngine/JoinHashTable/PerfectJoinHashTable.h"
#include "QueryEngine/JoinHashTable/Runtime/HashJoinKeyHandlers.h"
#include "QueryEngine/JoinHashTable/Runtime/JoinHashTableGpuUtils.h"

Include dependency graph for BaselineJoinHashTable.cpp:

Go to the source code of this file.

Macros
#define	LL_CONTEXT   executor_->cgen_state_->context_
#define	LL_BUILDER   executor_->cgen_state_->ir_builder_
#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
bool	needs_dictionary_translation (const std::vector< InnerOuter > &inner_outer_pairs, const std::vector< InnerOuterStringOpInfos > &inner_outer_string_op_infos_pairs, const Executor *executor)
StrProxyTranslationMapsPtrsAndOffsets	decomposeStrDictTranslationMaps (const std::vector< const StringDictionaryProxy::IdMap * > &str_proxy_translation_maps)

Macro Definition Documentation

#define LL_BUILDER   executor_->cgen_state_->ir_builder_

Definition at line 909 of file BaselineJoinHashTable.cpp.

Referenced by BaselineJoinHashTable::codegenKey(), BaselineJoinHashTable::codegenMatchingSet(), BaselineJoinHashTable::codegenSlot(), and BaselineJoinHashTable::hashPtr().

#define LL_CONTEXT   executor_->cgen_state_->context_

Definition at line 908 of file BaselineJoinHashTable.cpp.

Referenced by BaselineJoinHashTable::codegenKey(), BaselineJoinHashTable::codegenMatchingSet(), BaselineJoinHashTable::codegenSlot(), and BaselineJoinHashTable::hashPtr().

#define LL_FP

(

v

)

executor_->cgen_state_->llFp(v)

Definition at line 911 of file BaselineJoinHashTable.cpp.

#define LL_INT

(

v

)

executor_->cgen_state_->llInt(v)

Definition at line 910 of file BaselineJoinHashTable.cpp.

Referenced by BaselineJoinHashTable::codegenKey(), BaselineJoinHashTable::codegenMatchingSet(), and BaselineJoinHashTable::codegenSlot().

#define ROW_FUNC   executor_->cgen_state_->row_func_

Definition at line 912 of file BaselineJoinHashTable.cpp.

Function Documentation

StrProxyTranslationMapsPtrsAndOffsets decomposeStrDictTranslationMaps

(

const std::vector< const StringDictionaryProxy::IdMap * > &

str_proxy_translation_maps

)

Definition at line 751 of file BaselineJoinHashTable.cpp.

Referenced by BaselineJoinHashTable::initHashTableForDevice().

                                                                                    {
  StrProxyTranslationMapsPtrsAndOffsets translation_map_ptrs_and_offsets;
  // First element of pair is vector of int32_t* pointing to translation map "vector"
  // Second element of pair is vector of int32_t of min inner dictionary ids (offsets)
  const size_t num_translation_maps = str_proxy_translation_maps.size();
  translation_map_ptrs_and_offsets.first.reserve(num_translation_maps);
  translation_map_ptrs_and_offsets.second.reserve(num_translation_maps);
  for (const auto& str_proxy_translation_map : str_proxy_translation_maps) {
    if (str_proxy_translation_map) {
      translation_map_ptrs_and_offsets.first.emplace_back(
          str_proxy_translation_map->data());
      translation_map_ptrs_and_offsets.second.emplace_back(
          str_proxy_translation_map->domainStart());
    } else {
      // dummy values
      translation_map_ptrs_and_offsets.first.emplace_back(nullptr);
      translation_map_ptrs_and_offsets.second.emplace_back(0);
    }
  }
  return translation_map_ptrs_and_offsets;
}

Here is the caller graph for this function:

bool needs_dictionary_translation	(	const std::vector< InnerOuter > &	inner_outer_pairs,
		const std::vector< InnerOuterStringOpInfos > &	inner_outer_string_op_infos_pairs,
		const Executor *	executor
	)

Definition at line 243 of file BaselineJoinHashTable.cpp.

References CHECK_EQ.

Referenced by PerfectJoinHashTable::getEffectiveMemoryLevel(), BaselineJoinHashTable::getEffectiveMemoryLevel(), and PerfectJoinHashTable::reify().

                              {
  const auto num_col_pairs = inner_outer_pairs.size();
  CHECK_EQ(num_col_pairs, inner_outer_string_op_infos_pairs.size());
  for (size_t col_pair_idx = 0; col_pair_idx < num_col_pairs; ++col_pair_idx) {
    if (needs_dictionary_translation(inner_outer_pairs[col_pair_idx],
                                     inner_outer_string_op_infos_pairs[col_pair_idx],
                                     executor)) {
      return true;
    }
  }
  return false;
}

Here is the caller graph for this function: