#include <AbstractTextFileDataWrapper.h>

Collaboration diagram for foreign_storage::IterativeFileScanParameters:

Public Member Functions
	IterativeFileScanParameters (std::map< int, Chunk_NS::Chunk > &column_id_to_chunk_map, int32_t fragment_id, AbstractBuffer *delete_buffer)

std::mutex &	getChunkMutex (const int col_id) const

std::condition_variable &	getChunkConditionalVariable (const int col_id) const

Public Attributes
std::map< int, Chunk_NS::Chunk > &	column_id_to_chunk_map

int32_t	fragment_id

AbstractBuffer *	delete_buffer

std::map< int, std::unique_ptr < std::mutex > >	column_id_to_chunk_mutex

std::map< int, std::unique_ptr < std::condition_variable > >	column_id_to_chunk_conditional_var

std::mutex	delete_buffer_mutex

Detailed Description

Definition at line 56 of file AbstractTextFileDataWrapper.h.

Constructor & Destructor Documentation

foreign_storage::IterativeFileScanParameters::IterativeFileScanParameters	(	std::map< int, Chunk_NS::Chunk > &	column_id_to_chunk_map,
		int32_t	fragment_id,
		AbstractBuffer *	delete_buffer
	)

inline

Definition at line 66 of file AbstractTextFileDataWrapper.h.

References column_id_to_chunk_conditional_var, and column_id_to_chunk_mutex.

       : column_id_to_chunk_map(column_id_to_chunk_map)
       , fragment_id(fragment_id)
       , delete_buffer(delete_buffer) {
     for (const auto& [key, _] : column_id_to_chunk_map) {
       column_id_to_chunk_mutex[key] = std::make_unique<std::mutex>();
       column_id_to_chunk_conditional_var[key] =
           std::make_unique<std::condition_variable>();
     }
   }

Member Function Documentation

std::condition_variable& foreign_storage::IterativeFileScanParameters::getChunkConditionalVariable ( const int col_id ) const

inline

Definition at line 85 of file AbstractTextFileDataWrapper.h.

References CHECK, and column_id_to_chunk_conditional_var.

Referenced by foreign_storage::append_data_block_to_chunk().

                                                                              {
     auto var_it = column_id_to_chunk_conditional_var.find(col_id);
     CHECK(var_it != column_id_to_chunk_conditional_var.end());
     return *var_it->second;
   }

Here is the caller graph for this function:

std::mutex& foreign_storage::IterativeFileScanParameters::getChunkMutex ( const int col_id ) const

inline

Definition at line 79 of file AbstractTextFileDataWrapper.h.

References CHECK, and column_id_to_chunk_mutex.

Referenced by foreign_storage::append_data_block_to_chunk().

                                                   {
     auto mutex_it = column_id_to_chunk_mutex.find(col_id);
     CHECK(mutex_it != column_id_to_chunk_mutex.end());
     return *mutex_it->second;
   }