MCPcopy Create free account
hub / github.com/ByConity/ByConity / add

Method add

src/Databases/MySQL/MaterializeMySQLSyncThread.cpp:743–749  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

741}
742
743void MaterializeMySQLSyncThread::Buffers::add(size_t block_rows, size_t block_bytes, size_t written_rows, size_t written_bytes)
744{
745 total_blocks_rows += written_rows;
746 total_blocks_bytes += written_bytes;
747 max_block_rows = std::max(block_rows, max_block_rows);
748 max_block_bytes = std::max(block_bytes, max_block_bytes);
749}
750
751bool MaterializeMySQLSyncThread::Buffers::checkThresholds(size_t check_block_rows, size_t check_block_bytes, size_t check_total_rows, size_t check_total_bytes) const
752{

Callers 8

clearDataMethod · 0.45
executeDDLQueryMethod · 0.45
runResyncTableTaskMethod · 0.45
doResyncTableMethod · 0.45
recordExceptionFunction · 0.45
fetchTablesColumnsListFunction · 0.45
onEventMethod · 0.45

Calls 1

maxFunction · 0.50

Tested by

no test coverage detected