Remove unused code

This commit is contained in:
Raúl Marín 2023-07-24 15:16:44 +02:00
parent b225f9c34b
commit c7239c64ea

View File

@ -145,9 +145,6 @@ bool IMergeTreeSelectAlgorithm::getNewTask()
ChunkAndProgress IMergeTreeSelectAlgorithm::read()
{
size_t num_read_rows = 0;
size_t num_read_bytes = 0;
while (!is_cancelled)
{
try
@ -178,10 +175,6 @@ ChunkAndProgress IMergeTreeSelectAlgorithm::read()
ordered_columns.push_back(res.block.getByName(name).column);
}
/// Account a progress from previous empty chunks.
res.num_read_rows += num_read_rows;
res.num_read_bytes += num_read_bytes;
return ChunkAndProgress{
.chunk = Chunk(ordered_columns, res.row_count),
.num_read_rows = res.num_read_rows,
@ -194,7 +187,7 @@ ChunkAndProgress IMergeTreeSelectAlgorithm::read()
}
}
return {Chunk(), num_read_rows, num_read_bytes, true};
return {Chunk(), 0, 0, true};
}
void IMergeTreeSelectAlgorithm::initializeMergeTreeReadersForCurrentTask(