#include <ExecutionKernel.h>

Collaboration diagram for SharedKernelContext:

Public Member Functions
	SharedKernelContext (const std::vector< InputTableInfo > &query_infos)

const std::vector< uint64_t > &	getFragOffsets ()

void	addDeviceResults (ResultSetPtr &&device_results, std::vector< size_t > outer_table_fragment_ids)

std::vector< std::pair < ResultSetPtr, std::vector < size_t > > > &	getFragmentResults ()

const std::vector < InputTableInfo > &	getQueryInfos () const

Public Attributes
std::atomic_flag	dynamic_watchdog_set = ATOMIC_FLAG_INIT

Private Attributes
std::mutex	reduce_mutex_

std::vector< std::pair < ResultSetPtr, std::vector < size_t > > >	all_fragment_results_

std::vector< uint64_t >	all_frag_row_offsets_

std::mutex	all_frag_row_offsets_mutex_

const std::vector < InputTableInfo > &	query_infos_

const RegisteredQueryHint	query_hint_

Detailed Description

Definition at line 29 of file ExecutionKernel.h.

Constructor & Destructor Documentation

SharedKernelContext::SharedKernelContext ( const std::vector< InputTableInfo > & query_infos )

inline

Definition at line 31 of file ExecutionKernel.h.

       : query_infos_(query_infos)
 #ifdef HAVE_TBB
       , task_group_(nullptr)
 #endif
   {
   }

Member Function Documentation

void SharedKernelContext::addDeviceResults	(	ResultSetPtr &&	device_results,
		std::vector< size_t >	outer_table_fragment_ids
	)

Definition at line 115 of file ExecutionKernel.cpp.

References all_fragment_results_, anonymous_namespace{ExecutionKernel.cpp}::needs_skip_result(), and reduce_mutex_.

Referenced by Executor::launchKernels(), and ExecutionKernel::runImpl().

                                                                                        {
   std::lock_guard<std::mutex> lock(reduce_mutex_);
   if (!needs_skip_result(device_results)) {
     all_fragment_results_.emplace_back(std::move(device_results),
                                        outer_table_fragment_ids);
   }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

std::vector< std::pair< ResultSetPtr, std::vector< size_t > > > & SharedKernelContext::getFragmentResults ( )

Definition at line 125 of file ExecutionKernel.cpp.

References all_fragment_results_.

Referenced by Executor::collectAllDeviceResults(), Executor::collectAllDeviceShardedTopResults(), Executor::executeUpdate(), Executor::executeWorkUnitPerFragment(), and Executor::resultsUnion().

                                         {
   return all_fragment_results_;
 }

Here is the caller graph for this function:

const std::vector< uint64_t > & SharedKernelContext::getFragOffsets ( )

Definition at line 102 of file ExecutionKernel.cpp.

References all_frag_row_offsets_, all_frag_row_offsets_mutex_, and query_infos_.

Referenced by Executor::createKernels(), Executor::executeUpdate(), and ExecutionKernel::runImpl().

                                                                {
   std::lock_guard<std::mutex> lock(all_frag_row_offsets_mutex_);
   if (all_frag_row_offsets_.empty()) {
     all_frag_row_offsets_.resize(query_infos_.front().info.fragments.size() + 1);
     for (size_t i = 1; i <= query_infos_.front().info.fragments.size(); ++i) {
       all_frag_row_offsets_[i] =
           all_frag_row_offsets_[i - 1] +
           query_infos_.front().info.fragments[i - 1].getNumTuples();
     }
   }
   return all_frag_row_offsets_;
 }