anonymous_namespace{TableFunctionExecutionContext.cpp} Namespace Reference

Enumerations
enum	{   MANAGER, ERROR_BUFFER, COL_BUFFERS, COL_SIZES,   INPUT_STR_DICT_PROXIES, OUTPUT_BUFFERS, OUTPUT_STR_DICT_PROXIES, OUTPUT_ROW_COUNT,   KERNEL_PARAM_COUNT }

Functions
void	append_literal_buffer (const Datum &d, const SQLTypeInfo &ti, int8_t *literal_buffer, int64_t offset)
size_t	get_output_row_count (const TableFunctionExecutionUnit &exe_unit, size_t input_element_count)

Enumeration Type Documentation

anonymous enum

Enumerator
MANAGER
ERROR_BUFFER
COL_BUFFERS
COL_SIZES
INPUT_STR_DICT_PROXIES
OUTPUT_BUFFERS
OUTPUT_STR_DICT_PROXIES
OUTPUT_ROW_COUNT
KERNEL_PARAM_COUNT

Definition at line 648 of file TableFunctionExecutionContext.cpp.

     {
  MANAGER,
  ERROR_BUFFER,
  COL_BUFFERS,
  COL_SIZES,
  INPUT_STR_DICT_PROXIES,
  OUTPUT_BUFFERS,
  OUTPUT_STR_DICT_PROXIES,
  OUTPUT_ROW_COUNT,
  KERNEL_PARAM_COUNT,
};

Function Documentation

void anonymous_namespace{TableFunctionExecutionContext.cpp}::append_literal_buffer	(	const Datum &	d,
		const SQLTypeInfo &	ti,
		int8_t *	literal_buffer,
		int64_t	offset
	)

Definition at line 31 of file TableFunctionExecutionContext.cpp.

References Datum::bigintval, Datum::boolval, DatumToString(), Datum::doubleval, Datum::floatval, get_bit_width(), Datum::intval, SQLTypeInfo::is_boolean(), SQLTypeInfo::is_fp(), SQLTypeInfo::is_integer(), SQLTypeInfo::is_text_encoding_none(), SQLTypeInfo::is_timeinterval(), SQLTypeInfo::is_timestamp(), Datum::smallintval, Datum::stringval, Datum::tinyintval, and UNREACHABLE.

Referenced by TableFunctionExecutionContext::execute().

                                           {
  if (ti.is_fp()) {
    switch (get_bit_width(ti)) {
      case 32:
        std::memcpy(literal_buffer + offset, &d.floatval, sizeof(float));
        break;
      case 64:
        std::memcpy(literal_buffer + offset, &d.doubleval, sizeof(double));
        break;
      default:
        UNREACHABLE();
    }
  } else if (ti.is_integer() || ti.is_timestamp() || ti.is_timeinterval()) {
    switch (get_bit_width(ti)) {
      case 8:
        std::memcpy(literal_buffer + offset, &d.tinyintval, sizeof(int8_t));
        break;
      case 16:
        std::memcpy(literal_buffer + offset, &d.smallintval, sizeof(int16_t));
        break;
      case 32:
        std::memcpy(literal_buffer + offset, &d.intval, sizeof(int32_t));
        break;
      case 64:
        std::memcpy(literal_buffer + offset, &d.bigintval, sizeof(int64_t));
        break;
      default:
        UNREACHABLE();
    }
  } else if (ti.is_boolean()) {
    std::memcpy(literal_buffer + offset, &d.boolval, sizeof(int8_t));
  } else if (ti.is_text_encoding_none()) {
    auto string_size = d.stringval->size();
    std::memcpy(literal_buffer + offset, &string_size, sizeof(int64_t));
    std::memcpy(
        literal_buffer + offset + sizeof(int64_t), d.stringval->data(), string_size);
  } else {
    throw TableFunctionError("Literal value " + DatumToString(d, ti) +
                             " is not yet supported.");
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

size_t anonymous_namespace{TableFunctionExecutionContext.cpp}::get_output_row_count	(	const TableFunctionExecutionUnit &	exe_unit,
		size_t	input_element_count
	)

Definition at line 76 of file TableFunctionExecutionContext.cpp.

References table_functions::TableFunction::getOutputRowSizeType(), table_functions::kConstant, table_functions::kPreFlightParameter, table_functions::kTableFunctionSpecifiedParameter, table_functions::kUserSpecifiedConstantParameter, table_functions::kUserSpecifiedRowMultiplier, TableFunctionExecutionUnit::output_buffer_size_param, TableFunctionExecutionUnit::table_func, and UNREACHABLE.

Referenced by TableFunctionExecutionContext::launchCpuCode(), and TableFunctionExecutionContext::launchGpuCode().

                                                        {
  size_t allocated_output_row_count = 0;
  switch (exe_unit.table_func.getOutputRowSizeType()) {
    case table_functions::OutputBufferSizeType::kConstant:
    case table_functions::OutputBufferSizeType::kUserSpecifiedConstantParameter:
    case table_functions::OutputBufferSizeType::kPreFlightParameter: {
      allocated_output_row_count = exe_unit.output_buffer_size_param;
      break;
    }
    case table_functions::OutputBufferSizeType::kUserSpecifiedRowMultiplier: {
      allocated_output_row_count =
          exe_unit.output_buffer_size_param * input_element_count;
      break;
    }
    case table_functions::OutputBufferSizeType::kTableFunctionSpecifiedParameter: {
      allocated_output_row_count = input_element_count;
      break;
    }
    default: {
      UNREACHABLE();
    }
  }
  return allocated_output_row_count;
}

Here is the call graph for this function:

Here is the caller graph for this function: