thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename method

Browse Source
This commit is contained in:
Igor Nikonov 2024-07-19 09:34:20 +00:00
parent e806123856
commit 4cb862432c
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/IProcessor.h
View File

@ -221,7 +221,7 @@ public:
throw Exception(ErrorCodes::NOT_IMPLEMENTED, "Method 'schedule' is not implemented for {} processor", getName()); throw Exception(ErrorCodes::NOT_IMPLEMENTED, "Method 'schedule' is not implemented for {} processor", getName());
} }
virtual void asyncJobReady() {} virtual void onAsyncJobReady() {}
/** You must call this method if 'prepare' returned ExpandPipeline. /** You must call this method if 'prepare' returned ExpandPipeline.
* This method cannot access any port, but it can create new ports for current processor. * This method cannot access any port, but it can create new ports for current processor.

2
src/Processors/Sources/RemoteSource.cpp
View File

@ -104,7 +104,7 @@ void RemoteSource::work()
ISource::work(); ISource::work();
} }
void RemoteSource::asyncJobReady() void RemoteSource::onAsyncJobReady()
{ {
chassert(async_read); chassert(async_read);

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

@ -32,7 +32,7 @@ public:
int schedule() override { return fd; } int schedule() override { return fd; }
void asyncJobReady() override; void onAsyncJobReady() override;
void setStorageLimits(const std::shared_ptr<const StorageLimitsList> & storage_limits_) override; void setStorageLimits(const std::shared_ptr<const StorageLimitsList> & storage_limits_) override;