Changed-lines coverage: PR changed C/C++ lines covered by tests: 96.04% (315/328) Uncovered changed code (with context): ================================================================================ src/Processors/QueryPlan/ReadFromMemoryStorageStep.cpp ================================================================================ --- uncovered block 264-265 --- 262 | if (constant_filter.always_false) 263 | { >> 264 | progress(num_src_rows, num_read_bytes); >> 265 | return std::nullopt; 266 | } 267 | --- uncovered block 349-351 --- 347 | if (which.isNativeInt() || which.isNativeUInt()) 348 | return type->createColumnConst(num_rows, 1u)->convertToFullColumnIfConst(); >> 349 | if (which.isFloat()) >> 350 | return type->createColumnConst(num_rows, 1.0f)->convertToFullColumnIfConst(); >> 351 | throw Exception(ErrorCodes::ILLEGAL_TYPE_OF_COLUMN_FOR_FILTER, "Illegal type {} of column for filter", type->getName()); 352 | } 353 | ================================================================================ src/Storages/StorageMemory.cpp ================================================================================ --- uncovered block 355-355 --- 353 | /// swap in a possibly-truncated result. 354 | if (cancelled) >> 355 | throw_on_cancellation(); 356 | new_data = std::make_unique(); 357 | new_data->blocks = out; --- uncovered block 386-387 --- 384 | { 385 | if (out[i].rows() != old_blocks[i].rows()) >> 386 | reject_incomplete(fmt::format( >> 387 | "block {} has {} rows, expected {}", i, out[i].rows(), old_blocks[i].rows())); 388 | } 389 | --- uncovered block 702-702 --- 700 | 701 | /// Append old blocks with the new ones. >> 702 | auto old_and_new_data = std::make_unique(*(data.get())); 703 | old_and_new_data->blocks.insert( 704 | old_and_new_data->blocks.end(), std::make_move_iterator(new_blocks.begin()), std::make_move_iterator(new_blocks.end())); --- uncovered block 775-777 --- 773 | { 774 | if (query_context->getPinnedStorageSnapshot(getStorageID().uuid)) >> 775 | return false; 776 | if (query_context->hasQueryContext() && query_context->getQueryContext()->getPinnedStorageSnapshot(getStorageID().uuid)) >> 777 | return false; 778 | } 779 | return true; ================================================================================ src/Storages/StorageMemory.h ================================================================================ --- uncovered block 41-41 --- 39 | String getName() const override { return "Memory"; } 40 | >> 41 | size_t getSize() const { return data.get()->blocks.size(); } 42 | 43 | /// Snapshot for StorageMemory contains current set of blocks ================================================================================ src/Storages/StorageMerge.cpp ================================================================================ --- uncovered block 2567-2567 --- 2565 | const auto source_table_id = table->getStorageID(); 2566 | if (!source_table_id.hasDatabase()) >> 2567 | return false; 2568 | auto row_policy_filter = ctx->getRowPolicyFilter( 2569 | source_table_id.getDatabaseName(), source_table_id.getTableName(), RowPolicyFilterType::SELECT_FILTER); WARNING: Failed to get start time for [Print Uncovered Code] - start time and duration won't be set --- Coverage counts --- Lines : baseline 1,062,906/1,195,410 -> current 1,063,339/1,195,625 (delta +433 / +215) Functions : baseline 819,650/893,230 -> current 819,689/893,239 (delta +39 / +9) Branches : baseline 355,429/437,200 -> current 355,601/437,320 (delta +172 / +120)