thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-04 21:42:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix build, typos check

Browse Source
This commit is contained in:
kssenii 2021-04-27 17:01:41 +00:00
parent 3a0372535e
commit 563f8a97c6
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/IO/Progress.h
View File

@ -59,7 +59,7 @@ struct FileTableEngineProgress
mutable std::atomic<uint64_t> processed_bytes;
mutable std::atomic<uint64_t> processed_rows;
FileTableEngineProgress() : total_bytes_to_process(0), processed_bytes(0) {}
FileTableEngineProgress() : total_bytes_to_process(0), processed_bytes(0), processed_rows(0) {}
FileTableEngineProgress(const FileTableEngineProgress & other)
: watch(other.watch)

2
src/Processors/Sources/SourceWithProgress.h
View File

@ -54,7 +54,7 @@ public:
void setProcessListElement(QueryStatus * elem) final { process_list_elem = elem; }
void addTotalRowsApprox(size_t value) final { total_rows_approx += value; }
/// This method might be overriden, if, during query execution, there is a Source, that needs
/// This method might be overridden, if, during query execution, there is a Source, that needs
/// to add one more progress callback.
void setProgressCallback(const ProgressCallback & callback) override { progress_callback = callback; }

3
src/Storages/StorageFile.cpp
View File

@ -27,6 +27,7 @@
#include <fcntl.h>
#include <unistd.h>
#include <algorithm>
#include <Poco/Path.h>
#include <Poco/File.h>
@ -456,7 +457,7 @@ public:
};
size_t terminal_width = getTerminalWidth();
auto & file_progress = context->getFileTableEngineProgress();
const auto & file_progress = context->getFileTableEngineProgress();
WriteBufferFromFileDescriptor message(STDERR_FILENO, 1024);
if (!file_progress.processed_bytes)