#include "../Shared/sqltypes.h"
#include "BufferCompaction.h"
#include "TypePunning.h"
#include "Logger/Logger.h"

Include dependency graph for AggregateUtils.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	set_component (int8_t *group_by_buffer, const size_t comp_sz, const int64_t val, const size_t index=0)

int64_t	float_to_double_bin (int32_t val, bool nullable=false)

std::vector< int64_t >	compact_init_vals (const size_t cmpt_size, const std::vector< int64_t > &init_vec, const QueryMemoryDescriptor &query_mem_desc)

Function Documentation

std::vector<int64_t> compact_init_vals	(	const size_t	cmpt_size,
		const std::vector< int64_t > &	init_vec,
		const QueryMemoryDescriptor &	query_mem_desc
	)

inline

Definition at line 68 of file AggregateUtils.h.

References align_to_int64(), CHECK_LT, QueryMemoryDescriptor::getPaddedSlotWidthBytes(), QueryMemoryDescriptor::getSlotCount(), and set_component().

Referenced by QueryExecutionContext::copyInitAggValsToDevice(), and QueryExecutionContext::launchCpuCode().

                                                  {
   std::vector<int64_t> cmpt_res(cmpt_size, 0);
   int8_t* buffer_ptr = reinterpret_cast<int8_t*>(cmpt_res.data());
   for (size_t col_idx = 0, init_vec_idx = 0, col_count = query_mem_desc.getSlotCount();
        col_idx < col_count;
        ++col_idx) {
     const auto chosen_bytes =
         static_cast<unsigned>(query_mem_desc.getPaddedSlotWidthBytes(col_idx));
     if (chosen_bytes == 0) {
       continue;
     }
     if (chosen_bytes == sizeof(int64_t)) {
       buffer_ptr = align_to_int64(buffer_ptr);
     }
     CHECK_LT(init_vec_idx, init_vec.size());
     set_component(buffer_ptr, chosen_bytes, init_vec[init_vec_idx++]);
     buffer_ptr += chosen_bytes;
   }
   return cmpt_res;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

int64_t float_to_double_bin	(	int32_t	val,
		bool	nullable = `false`
	)

inline

Definition at line 58 of file AggregateUtils.h.

References NULL_DOUBLE, NULL_FLOAT, and run_benchmark_import::res.

Referenced by Executor::reduceResults().

                                                                        {
   const float null_float = NULL_FLOAT;
   if (nullable && val == *reinterpret_cast<const int32_t*>(may_alias_ptr(&null_float))) {
     double null_double = NULL_DOUBLE;
     return *reinterpret_cast<const int64_t*>(may_alias_ptr(&null_double));
   }
   double res = *reinterpret_cast<const float*>(may_alias_ptr(&val));
   return *reinterpret_cast<const int64_t*>(may_alias_ptr(&res));
 }

Here is the caller graph for this function:

void set_component	(	int8_t *	group_by_buffer,
		const size_t	comp_sz,
		const int64_t	val,
		const size_t	index = `0`
	)

inline

Definition at line 26 of file AggregateUtils.h.

References CHECK.

Referenced by compact_init_vals().

                                                   {
   switch (comp_sz) {
     case 1: {
       group_by_buffer[index] = static_cast<int8_t>(val);
       break;
     }
     case 2: {
       int16_t* buffer_ptr = reinterpret_cast<int16_t*>(group_by_buffer);
       buffer_ptr[index] = (int16_t)val;
       break;
     }
     case 4: {
       int32_t* buffer_ptr = reinterpret_cast<int32_t*>(group_by_buffer);
       buffer_ptr[index] = (int32_t)val;
       break;
     }
     case 8: {
       int64_t* buffer_ptr = reinterpret_cast<int64_t*>(group_by_buffer);
       buffer_ptr[index] = val;
       break;
     }
     case 0: {
       break;
     }
     default:
       CHECK(false);
   }
 }

Here is the caller graph for this function:

Functions

Function Documentation