OmniSciDB
c1a53651b2
|
Functions | |
int | compute_device_for_fragment (const int table_id, const int fragment_id, const int num_devices) |
size_t | get_num_rows_to_insert (const size_t rows_left_in_current_fragment, const size_t num_rows_left, const size_t num_rows_inserted, const std::unordered_map< int, size_t > &var_len_col_info, const size_t max_chunk_size, const InsertChunks &insert_chunks, std::map< int, Chunk_NS::Chunk > &column_map, const std::vector< size_t > &valid_row_indices) |
int Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::compute_device_for_fragment | ( | const int | table_id, |
const int | fragment_id, | ||
const int | num_devices | ||
) |
Offset the fragment ID by the table ID, meaning single fragment tables end up balanced across multiple GPUs instead of all falling to GPU 0.
Definition at line 103 of file InsertOrderFragmenter.cpp.
References g_use_table_device_offset.
Referenced by Fragmenter_Namespace::InsertOrderFragmenter::createNewFragment(), and Fragmenter_Namespace::InsertOrderFragmenter::getChunkMetadata().
size_t Fragmenter_Namespace::anonymous_namespace{InsertOrderFragmenter.cpp}::get_num_rows_to_insert | ( | const size_t | rows_left_in_current_fragment, |
const size_t | num_rows_left, | ||
const size_t | num_rows_inserted, | ||
const std::unordered_map< int, size_t > & | var_len_col_info, | ||
const size_t | max_chunk_size, | ||
const InsertChunks & | insert_chunks, | ||
std::map< int, Chunk_NS::Chunk > & | column_map, | ||
const std::vector< size_t > & | valid_row_indices | ||
) |
Definition at line 113 of file InsertOrderFragmenter.cpp.
References CHECK, CHECK_LE, and Fragmenter_Namespace::InsertChunks::chunks.
Referenced by Fragmenter_Namespace::InsertOrderFragmenter::insertChunksImpl().