37 const std::vector<InputTableInfo>& table_infos,
38 const std::shared_ptr<CompilationContext>& compilation_context,
42 bool is_pre_launch_udtf);
47 const std::shared_ptr<CpuCompilationContext>& compilation_context,
48 std::vector<const int8_t*>& col_buf_ptrs,
49 std::vector<int64_t>& col_sizes,
50 const size_t elem_count,
55 const std::shared_ptr<CpuCompilationContext>& compilation_context,
56 std::vector<const int8_t*>& col_buf_ptrs,
57 std::vector<int64_t>& col_sizes,
58 std::vector<const int8_t*>& input_str_dict_proxy_ptrs,
59 const size_t elem_count,
60 std::vector<int8_t*>& output_str_dict_proxy_ptrs,
65 const std::shared_ptr<GpuCompilationContext>& compilation_context,
66 std::vector<const int8_t*>& col_buf_ptrs,
67 std::vector<int64_t>& col_sizes,
68 std::vector<const int8_t*>& input_str_dict_proxy_ptrs,
69 const size_t elem_count,
70 std::vector<int8_t*>& output_str_dict_proxy_ptrs,
void launchPreCodeOnCpu(const TableFunctionExecutionUnit &exe_unit, const std::shared_ptr< CpuCompilationContext > &compilation_context, std::vector< const int8_t * > &col_buf_ptrs, std::vector< int64_t > &col_sizes, const size_t elem_count, Executor *executor)
std::shared_ptr< ResultSet > ResultSetPtr
std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner_
TableFunctionExecutionContext & operator=(const TableFunctionExecutionContext &)=delete
Executor(const ExecutorId id, Data_Namespace::DataMgr *data_mgr, const size_t block_size_x, const size_t grid_size_x, const size_t max_gpu_slab_size, const std::string &debug_dir, const std::string &debug_file)
ResultSetPtr launchCpuCode(const TableFunctionExecutionUnit &exe_unit, const std::shared_ptr< CpuCompilationContext > &compilation_context, std::vector< const int8_t * > &col_buf_ptrs, std::vector< int64_t > &col_sizes, std::vector< const int8_t * > &input_str_dict_proxy_ptrs, const size_t elem_count, std::vector< int8_t * > &output_str_dict_proxy_ptrs, Executor *executor)
ResultSetPtr execute(const TableFunctionExecutionUnit &exe_unit, const std::vector< InputTableInfo > &table_infos, const std::shared_ptr< CompilationContext > &compilation_context, const ColumnFetcher &column_fetcher, const ExecutorDeviceType device_type, Executor *executor, bool is_pre_launch_udtf)
Execution unit for relational algebra. It's a low-level description of any relational algebra operati...
TableFunctionExecutionContext(std::shared_ptr< RowSetMemoryOwner > row_set_mem_owner)
ResultSetPtr launchGpuCode(const TableFunctionExecutionUnit &exe_unit, const std::shared_ptr< GpuCompilationContext > &compilation_context, std::vector< const int8_t * > &col_buf_ptrs, std::vector< int64_t > &col_sizes, std::vector< const int8_t * > &input_str_dict_proxy_ptrs, const size_t elem_count, std::vector< int8_t * > &output_str_dict_proxy_ptrs, const int device_id, Executor *executor)