OmniSciDB
cde582ebc3
|
#include "QueryEngine/Descriptors/InputDescriptors.h"
#include "QueryEngine/RelAlgExecutionUnit.h"
#include <unordered_map>
Go to the source code of this file.
Classes | |
struct | InputTableInfo |
class | InputTableInfoCache |
Namespaces | |
Catalog_Namespace | |
Typedefs | |
using | TemporaryTables = std::unordered_map< int, const ResultSetPtr & > |
Functions | |
ChunkMetadataMap | synthesize_metadata (const ResultSet *rows) |
size_t | get_frag_count_of_table (const int table_id, Executor *executor) |
std::vector< InputTableInfo > | get_table_infos (const std::vector< InputDescriptor > &input_descs, Executor *executor) |
std::vector< InputTableInfo > | get_table_infos (const RelAlgExecutionUnit &ra_exe_unit, Executor *executor) |
Fragmenter_Namespace::TableInfo | build_table_info (const std::vector< const TableDescriptor * > &shard_tables) |
using TemporaryTables = std::unordered_map<int, const ResultSetPtr&> |
Definition at line 31 of file InputMetadata.h.
Fragmenter_Namespace::TableInfo build_table_info | ( | const std::vector< const TableDescriptor * > & | shard_tables | ) |
Definition at line 44 of file InputMetadata.cpp.
References CHECK, Fragmenter_Namespace::TableInfo::fragments, and Fragmenter_Namespace::TableInfo::setPhysicalNumTuples().
Referenced by InputTableInfoCache::getTableInfo().
size_t get_frag_count_of_table | ( | const int | table_id, |
Executor * | executor | ||
) |
Definition at line 430 of file InputMetadata.cpp.
References CHECK, and CHECK_GE.
Referenced by RelAlgExecutor::getOuterFragmentCount().
std::vector<InputTableInfo> get_table_infos | ( | const std::vector< InputDescriptor > & | input_descs, |
Executor * | executor | ||
) |
Definition at line 443 of file InputMetadata.cpp.
References anonymous_namespace{InputMetadata.cpp}::collect_table_infos().
Referenced by RelAlgExecutor::computeWindow(), RelAlgExecutor::createAggregateWorkUnit(), RelAlgExecutor::createCompoundWorkUnit(), RelAlgExecutor::createFilterWorkUnit(), RelAlgExecutor::createProjectWorkUnit(), RelAlgExecutor::createTableFunctionWorkUnit(), RelAlgExecutor::createUnionWorkUnit(), RelAlgExecutor::executeDelete(), RelAlgExecutor::executeTableFunction(), RelAlgExecutor::executeUpdate(), RelAlgExecutor::executeWorkUnit(), get_table_infos(), TableOptimizer::getDeletedColumnStats(), RelAlgExecutor::getFilteredCountAll(), RelAlgExecutor::getFilterSelectivity(), RelAlgExecutor::getNDVEstimation(), RelAlgExecutor::handleOutOfMemoryRetry(), TableOptimizer::recomputeColumnMetadata(), and RelAlgExecutor::selectFiltersToBePushedDown().
std::vector<InputTableInfo> get_table_infos | ( | const RelAlgExecutionUnit & | ra_exe_unit, |
Executor * | executor | ||
) |
Definition at line 451 of file InputMetadata.cpp.
References anonymous_namespace{InputMetadata.cpp}::collect_table_infos(), get_table_infos(), INJECT_TIMER, and RelAlgExecutionUnit::input_descs.
ChunkMetadataMap synthesize_metadata | ( | const ResultSet * | rows | ) |
Definition at line 306 of file InputMetadata.cpp.
References threading_serial::async(), CHECK, CHECK_LT, cpu_threads(), Encoder::Create(), DEBUG_TIMER, inline_fp_null_val(), inline_int_null_val(), kDOUBLE, kFLOAT, synthesize_metadata_table_function(), TableFunction, result_set::use_parallel_algorithms(), and anonymous_namespace{InputMetadata.cpp}::uses_int_meta().
Referenced by Fragmenter_Namespace::FragmentInfo::getChunkMetadataMap().