Processors: experimental [#CLICKHOUSE-2948]

This commit is contained in:
Alexey Milovidov 2018-05-20 08:30:47 +03:00
parent 7dfc0a4c6c
commit 969c0d9fc1
2 changed files with 4 additions and 4 deletions

View File

@ -280,7 +280,7 @@ public:
enum class Status
{
/// Processor needs some data at its inputs to proceed.
/// You need to run another processor to generate required input and proceed.
/// You need to run another processor to generate required input before proceed.
NeedData,
/// Processor cannot proceed because output port is full.

View File

@ -50,9 +50,6 @@ public:
Status prepare() override
{
if (output.hasData())
return Status::PortFull;
if (!output.isNeeded())
return Status::Unneeded;
@ -62,6 +59,9 @@ public:
if (!current_block)
return Status::Async;
if (output.hasData())
return Status::PortFull;
return Status::Ready;
}