anonymous_namespace{InputMetadata.cpp} Namespace Reference

Classes
union	Number64

Functions
Fragmenter_Namespace::TableInfo	copy_table_info (const Fragmenter_Namespace::TableInfo &table_info)
bool	uses_int_meta (const SQLTypeInfo &col_ti)
Fragmenter_Namespace::TableInfo	synthesize_table_info (const ResultSetPtr &rows)
void	collect_table_infos (std::vector< InputTableInfo > &table_infos, const std::vector< InputDescriptor > &input_descs, Executor *executor)

Function Documentation

void anonymous_namespace{InputMetadata.cpp}::collect_table_infos	(	std::vector< InputTableInfo > &	table_infos,
		const std::vector< InputDescriptor > &	input_descs,
		Executor *	executor
	)

Definition at line 107 of file InputMetadata.cpp.

References CHECK, CHECK_LT, copy_table_info(), logger::FATAL, LOG_IF, RESULT, synthesize_table_info(), and TABLE.

Referenced by get_table_infos().

                                             {
  const auto temporary_tables = executor->getTemporaryTables();
  std::unordered_map<shared::TableKey, size_t> info_cache;
  for (const auto& input_desc : input_descs) {
    const auto& table_key = input_desc.getTableKey();
    const auto cached_index_it = info_cache.find(table_key);
    if (cached_index_it != info_cache.end()) {
      CHECK_LT(cached_index_it->second, table_infos.size());
      table_infos.push_back(
          {table_key, copy_table_info(table_infos[cached_index_it->second].info)});
      continue;
    }

    if (input_desc.getSourceType() == InputSourceType::RESULT) {
      auto table_id = table_key.table_id;
      CHECK_LT(table_id, 0);
      CHECK(temporary_tables);
      const auto it = temporary_tables->find(table_id);
      LOG_IF(FATAL, it == temporary_tables->end())
          << "Failed to find previous query result for node " << -table_id;
      table_infos.push_back({{0, table_id}, synthesize_table_info(it->second)});
    } else {
      CHECK(input_desc.getSourceType() == InputSourceType::TABLE);
      table_infos.push_back({table_key, executor->getTableInfo(table_key)});
    }
    CHECK(!table_infos.empty());
    info_cache.insert(std::make_pair(table_key, table_infos.size() - 1));
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Fragmenter_Namespace::TableInfo anonymous_namespace{InputMetadata.cpp}::copy_table_info

(

const Fragmenter_Namespace::TableInfo &

table_info

)

Definition at line 33 of file InputMetadata.cpp.

References Fragmenter_Namespace::TableInfo::chunkKeyPrefix, Fragmenter_Namespace::TableInfo::fragments, Fragmenter_Namespace::TableInfo::getPhysicalNumTuples(), and Fragmenter_Namespace::TableInfo::setPhysicalNumTuples().

Referenced by collect_table_infos(), and InputTableInfoCache::getTableInfo().

                                                     {
  Fragmenter_Namespace::TableInfo table_info_copy;
  table_info_copy.chunkKeyPrefix = table_info.chunkKeyPrefix;
  table_info_copy.fragments = table_info.fragments;
  table_info_copy.setPhysicalNumTuples(table_info.getPhysicalNumTuples());
  return table_info_copy;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Fragmenter_Namespace::TableInfo anonymous_namespace{InputMetadata.cpp}::synthesize_table_info

(

const ResultSetPtr &

rows

)

Definition at line 92 of file InputMetadata.cpp.

References Fragmenter_Namespace::TableInfo::fragments, and run_benchmark_import::result.

Referenced by collect_table_infos().

                                                                              {
  std::vector<Fragmenter_Namespace::FragmentInfo> result;
  if (rows) {
    result.resize(1);
    auto& fragment = result.front();
    fragment.fragmentId = 0;
    fragment.deviceIds.resize(3);
    fragment.resultSet = rows.get();
    fragment.resultSetMutex.reset(new std::mutex());
  }
  Fragmenter_Namespace::TableInfo table_info;
  table_info.fragments = result;
  return table_info;
}

Here is the caller graph for this function:

bool anonymous_namespace{InputMetadata.cpp}::uses_int_meta

(

const SQLTypeInfo &

col_ti

)

Definition at line 86 of file InputMetadata.cpp.

References SQLTypeInfo::get_compression(), SQLTypeInfo::is_boolean(), SQLTypeInfo::is_decimal(), SQLTypeInfo::is_integer(), SQLTypeInfo::is_string(), SQLTypeInfo::is_time(), and kENCODING_DICT.

Referenced by synthesize_metadata().

                                              {
  return col_ti.is_integer() || col_ti.is_decimal() || col_ti.is_time() ||
         col_ti.is_boolean() ||
         (col_ti.is_string() && col_ti.get_compression() == kENCODING_DICT);
}

Here is the call graph for this function:

Here is the caller graph for this function: