mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-12 09:22:05 +00:00
28 lines
569 B
C++
28 lines
569 B
C++
#pragma once
|
|
|
|
#include <memory>
|
|
|
|
namespace DB
|
|
{
|
|
|
|
class Block;
|
|
class QueryPipeline;
|
|
class PullingAsyncPipelineExecutor;
|
|
class PullingPipelineExecutor;
|
|
|
|
/// Wrapper for `Pulling(Async)PipelineExecutor` to dynamically dispatch calls to the right executor
|
|
class DictionaryPipelineExecutor
|
|
{
|
|
public:
|
|
DictionaryPipelineExecutor(QueryPipeline & pipeline_, bool async);
|
|
bool pull(Block & block);
|
|
|
|
~DictionaryPipelineExecutor();
|
|
|
|
private:
|
|
std::unique_ptr<PullingAsyncPipelineExecutor> async_executor;
|
|
std::unique_ptr<PullingPipelineExecutor> executor;
|
|
};
|
|
|
|
}
|