InputMetadata.cpp File Reference

#include "InputMetadata.h"
#include "Execute.h"
#include "../Fragmenter/Fragmenter.h"
#include <future>

Include dependency graph for InputMetadata.cpp:

Go to the source code of this file.

Namespaces
	anonymous_namespace{InputMetadata.cpp}

Functions
Fragmenter_Namespace::TableInfo	anonymous_namespace{InputMetadata.cpp}::copy_table_info (const Fragmenter_Namespace::TableInfo &table_info)
Fragmenter_Namespace::TableInfo	anonymous_namespace{InputMetadata.cpp}::build_table_info (const std::vector< const TableDescriptor *> &shard_tables)
bool	anonymous_namespace{InputMetadata.cpp}::uses_int_meta (const SQLTypeInfo &col_ti)
std::map< int, ChunkMetadata >	anonymous_namespace{InputMetadata.cpp}::synthesize_metadata (const ResultSet *rows)
Fragmenter_Namespace::TableInfo	anonymous_namespace{InputMetadata.cpp}::synthesize_table_info (const ResultSetPtr &rows)
void	anonymous_namespace{InputMetadata.cpp}::collect_table_infos (std::vector< InputTableInfo > &table_infos, const std::vector< InputDescriptor > &input_descs, Executor *executor)
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)

Function Documentation

get_frag_count_of_table()

size_t get_frag_count_of_table	(	const int	table_id,
		Executor *	executor
	)

Definition at line 237 of file InputMetadata.cpp.

References CHECK, and CHECK_GE.

                                                                       {
  const auto temporary_tables = executor->getTemporaryTables();
  CHECK(temporary_tables);
  auto it = temporary_tables->find(table_id);
  if (it != temporary_tables->end()) {
    CHECK_GE(int(0), table_id);
    return size_t(1);
  } else {
    const auto table_info = executor->getTableInfo(table_id);
    return table_info.fragments.size();
  }
}

get_table_infos() [1/2]

std::vector<InputTableInfo> get_table_infos	(	const std::vector< InputDescriptor > &	input_descs,
		Executor *	executor
	)

Definition at line 250 of file InputMetadata.cpp.

References anonymous_namespace{InputMetadata.cpp}::collect_table_infos().

Referenced by RelAlgExecutor::computeWindow(), RelAlgExecutor::createCompoundWorkUnit(), RelAlgExecutor::createProjectWorkUnit(), RelAlgExecutor::createTableFunctionWorkUnit(), RelAlgExecutor::executeDeleteViaCompound(), RelAlgExecutor::executeDeleteViaProject(), RelAlgExecutor::executeTableFunction(), RelAlgExecutor::executeUpdateViaCompound(), RelAlgExecutor::executeUpdateViaProject(), RelAlgExecutor::executeWorkUnit(), get_table_infos(), RelAlgExecutor::getFilteredCountAll(), RelAlgExecutor::getFilterSelectivity(), RelAlgExecutor::getNDVEstimation(), RelAlgExecutor::handleOutOfMemoryRetry(), TableOptimizer::recomputeMetadata(), and RelAlgExecutor::selectFiltersToBePushedDown().

                        {
  std::vector<InputTableInfo> table_infos;
  collect_table_infos(table_infos, input_descs, executor);
  return table_infos;
}

Here is the call graph for this function:

Here is the caller graph for this function:

get_table_infos() [2/2]

std::vector<InputTableInfo> get_table_infos	(	const RelAlgExecutionUnit &	ra_exe_unit,
		Executor *	executor
	)

Definition at line 258 of file InputMetadata.cpp.

References anonymous_namespace{InputMetadata.cpp}::collect_table_infos(), get_table_infos(), INJECT_TIMER, and RelAlgExecutionUnit::input_descs.

                                                                {
  INJECT_TIMER(get_table_infos);
  std::vector<InputTableInfo> table_infos;
  collect_table_infos(table_infos, ra_exe_unit.input_descs, executor);
  return table_infos;
}

Here is the call graph for this function: