#include "QueryEngine/OmniSciTypes.h"

Include dependency graph for UtilityTableFunctions.h:

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

Functions
EXTENSION_NOINLINE int32_t	generate_series_parallel (const int64_t start, const int64_t stop, const int64_t step, Column< int64_t > &series_output)

EXTENSION_NOINLINE int32_t	generate_series__cpu_1 (TableFunctionManager &mgr, const int64_t start, const int64_t stop, const int64_t step, Column< int64_t > &series_output)

EXTENSION_NOINLINE int32_t	generate_series__cpu_2 (TableFunctionManager &mgr, const int64_t start, const int64_t stop, Column< int64_t > &series_output)

Function Documentation

EXTENSION_NOINLINE int32_t generate_series__cpu_1	(	TableFunctionManager &	mgr,
		const int64_t	start,
		const int64_t	stop,
		const int64_t	step,
		Column< int64_t > &	series_output
	)

Definition at line 57 of file UtilityTableFunctions.cpp.

References generate_series_parallel(), TableFunctionManager::set_output_row_size(), and to_string().

Referenced by generate_series__cpu_2().

                                                                {
   const int64_t MAX_ROWS{1L << 30};
   const int64_t PARALLEL_THRESHOLD{10000L};
   const int64_t num_rows = ((stop - start) / step) + 1;
   if (num_rows <= 0) {
     mgr.set_output_row_size(0);
     return 0;
   }
   mgr.set_output_row_size(num_rows);
 
   if (num_rows > MAX_ROWS) {
     return mgr.ERROR_MESSAGE(
         "Invocation of generate_series would result in " + std::to_string(num_rows) +
         " rows, which exceeds the max limit of " + std::to_string(MAX_ROWS) + " rows.");
   }
 
 #ifdef HAVE_TBB
   if (num_rows > PARALLEL_THRESHOLD) {
     return generate_series_parallel(start, stop, step, series_output);
   }
 #endif
 
   for (int64_t out_idx = 0; out_idx != num_rows; ++out_idx) {
     series_output[out_idx] = start + out_idx * step;
   }
   return num_rows;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

EXTENSION_NOINLINE int32_t generate_series__cpu_2	(	TableFunctionManager &	mgr,
		const int64_t	start,
		const int64_t	stop,
		Column< int64_t > &	series_output
	)

Definition at line 95 of file UtilityTableFunctions.cpp.

References generate_series__cpu_1().

                                                                {
   return generate_series__cpu_1(mgr, start, stop, 1, series_output);
 }

Here is the call graph for this function:

EXTENSION_NOINLINE int32_t generate_series_parallel	(	const int64_t	start,
		const int64_t	stop,
		const int64_t	step,
		Column< int64_t > &	series_output
	)

Definition at line 33 of file UtilityTableFunctions.cpp.

References threading_serial::parallel_for().

Referenced by generate_series__cpu_1().

                                                                  {
   const int64_t num_rows = ((stop - start) / step) + 1;
 
   tbb::parallel_for(tbb::blocked_range<int64_t>(0, num_rows),
                     [&](const tbb::blocked_range<int64_t>& r) {
                       const int64_t start_out_idx = r.begin();
                       const int64_t end_out_idx = r.end();
                       for (int64_t out_idx = start_out_idx; out_idx != end_out_idx;
                            ++out_idx) {
                         series_output[out_idx] = start + out_idx * step;
                       }
                     });
   return num_rows;
 }

Here is the call graph for this function:

Here is the caller graph for this function: