Class SharedKernelContext

class SharedKernelContext

Public 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 Members

std::atomic_flag dynamic_watchdog_set = ATOMIC_FLAG_INIT

Private Members

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_