foreign_storage::anonymous_namespace{CsvDataWrapper.cpp} Namespace Reference

Functions
std::set< const ColumnDescriptor * >	get_columns (const std::map< ChunkKey, AbstractBuffer *> &buffers, std::shared_ptr< Catalog_Namespace::Catalog > catalog, const int32_t table_id, const int fragment_id)

Function Documentation

get_columns()

std::set<const ColumnDescriptor*> foreign_storage::anonymous_namespace{CsvDataWrapper.cpp}::get_columns	(	const std::map< ChunkKey, AbstractBuffer *> &	buffers,
		std::shared_ptr< Catalog_Namespace::Catalog >	catalog,
		const int32_t	table_id,
		const int	fragment_id
	)

Definition at line 167 of file CsvDataWrapper.cpp.

References CHECK, CHECK_EQ, CHUNK_KEY_COLUMN_IDX, and CHUNK_KEY_FRAGMENT_IDX.

Referenced by foreign_storage::CsvDataWrapper::populateChunkBuffers().

                           {
  CHECK(!buffers.empty());
  std::set<const ColumnDescriptor*> columns;
  for (const auto& entry : buffers) {
    CHECK_EQ(fragment_id, entry.first[CHUNK_KEY_FRAGMENT_IDX]);
    const auto column_id = entry.first[CHUNK_KEY_COLUMN_IDX];
    const auto column = catalog->getMetadataForColumnUnlocked(table_id, column_id);
    columns.emplace(column);
  }
  return columns;
}

Here is the caller graph for this function: