#include <HashJoinKeyHandlers.h>

Collaboration diagram for GenericKeyHandler:

Public Member Functions
	GenericKeyHandler (const size_t key_component_count, const bool should_skip_entries, const JoinColumn join_column_per_key, const JoinColumnTypeInfo type_info_per_key, const int32_t const sd_inner_to_outer_translation_maps, const int32_t *sd_min_inner_elems)

template<typename T , typename KEY_BUFF_HANDLER >
DEVICE int	operator() (JoinColumnIterator join_column_iterators, T key_scratch_buff, KEY_BUFF_HANDLER f) const

DEVICE size_t	get_number_of_columns () const

DEVICE size_t	get_key_component_count () const

DEVICE const JoinColumn *	get_join_columns () const

DEVICE const JoinColumnTypeInfo *	get_join_column_type_infos () const

Public Attributes
const size_t	key_component_count_

const bool	should_skip_entries_

const JoinColumn *	join_column_per_key_

const JoinColumnTypeInfo *	type_info_per_key_

const int32_t const	sd_inner_to_outer_translation_maps_

const int32_t *	sd_min_inner_elems_

Detailed Description

Definition at line 39 of file HashJoinKeyHandlers.h.

Constructor & Destructor Documentation

GenericKeyHandler::GenericKeyHandler	(	const size_t	key_component_count,
		const bool	should_skip_entries,
		const JoinColumn *	join_column_per_key,
		const JoinColumnTypeInfo *	type_info_per_key,
		const int32_t const	sd_inner_to_outer_translation_maps,
		const int32_t *	sd_min_inner_elems
	)

inline

Definition at line 40 of file HashJoinKeyHandlers.h.

References CHECK, sd_inner_to_outer_translation_maps_, and sd_min_inner_elems_.

       : key_component_count_(key_component_count)
       , should_skip_entries_(should_skip_entries)
       , join_column_per_key_(join_column_per_key)
       , type_info_per_key_(type_info_per_key) {
 #ifndef __CUDACC__
     if (sd_inner_to_outer_translation_maps) {
       CHECK(sd_min_inner_elems);
       sd_inner_to_outer_translation_maps_ = sd_inner_to_outer_translation_maps;
       sd_min_inner_elems_ = sd_min_inner_elems;
     } else
 #endif
     {
       sd_inner_to_outer_translation_maps_ = nullptr;
       sd_min_inner_elems_ = nullptr;
     }
   }

Member Function Documentation

DEVICE const JoinColumnTypeInfo* GenericKeyHandler::get_join_column_type_infos ( ) const

inline

Definition at line 121 of file HashJoinKeyHandlers.h.

References type_info_per_key_.

                                                                       {
     return type_info_per_key_;
   }

DEVICE const JoinColumn* GenericKeyHandler::get_join_columns ( ) const

inline

Definition at line 117 of file HashJoinKeyHandlers.h.

References join_column_per_key_.

                                                     {
     return join_column_per_key_;
   }

DEVICE size_t GenericKeyHandler::get_key_component_count ( ) const

inline

Definition at line 113 of file HashJoinKeyHandlers.h.

References key_component_count_.

                                                 {
     return key_component_count_;
   }

DEVICE size_t GenericKeyHandler::get_number_of_columns ( ) const

inline

Definition at line 109 of file HashJoinKeyHandlers.h.

References key_component_count_.

                                               {
     return key_component_count_;
   }

template<typename T , typename KEY_BUFF_HANDLER >

DEVICE int GenericKeyHandler::operator()	(	JoinColumnIterator *	join_column_iterators,
		T *	key_scratch_buff,
		KEY_BUFF_HANDLER	f
	)		const

inline

Definition at line 68 of file HashJoinKeyHandlers.h.

References f(), StringDictionary::INVALID_STR_ID, key_component_count_, sd_inner_to_outer_translation_maps_, sd_min_inner_elems_, and should_skip_entries_.

                                                   {
     bool skip_entry = false;
     for (size_t key_component_index = 0; key_component_index < key_component_count_;
          ++key_component_index) {
       const auto& join_column_iterator = join_column_iterators[key_component_index];
       int64_t elem = (*join_column_iterator).element;
       if (should_skip_entries_ && elem == join_column_iterator.type_info->null_val &&
           !join_column_iterator.type_info->uses_bw_eq) {
         skip_entry = true;
         break;
       }
 #ifndef __CUDACC__
       // Translation map pts will already be set to nullptr if invalid
       if (sd_inner_to_outer_translation_maps_) {
         const auto sd_inner_to_outer_translation_map =
             sd_inner_to_outer_translation_maps_[key_component_index];
         const auto sd_min_inner_elem = sd_min_inner_elems_[key_component_index];
         if (sd_inner_to_outer_translation_map &&
             elem != join_column_iterator.type_info->null_val) {
           const auto outer_id =
               sd_inner_to_outer_translation_map[elem - sd_min_inner_elem];
           if (outer_id == StringDictionary::INVALID_STR_ID) {
             skip_entry = true;
             break;
           }
           elem = outer_id;
         }
       }
 #endif
       key_scratch_buff[key_component_index] = elem;
     }
 
     if (!skip_entry) {
       return f(join_column_iterators[0].index, key_scratch_buff, key_component_count_);
     }
 
     return 0;
   }