mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-26 19:50:51 +00:00
Fix build.
This commit is contained in:
parent
00bccfa232
commit
062407cf14
@ -259,8 +259,8 @@ try
|
|||||||
// WriteBufferFromOStream out(std::cout);
|
// WriteBufferFromOStream out(std::cout);
|
||||||
// printPipeline(processors, out);
|
// printPipeline(processors, out);
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
sink->checkAllRead();
|
sink->checkAllRead();
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -347,8 +347,8 @@ try
|
|||||||
// WriteBufferFromOStream out(std::cout);
|
// WriteBufferFromOStream out(std::cout);
|
||||||
// printPipeline(processors, out);
|
// printPipeline(processors, out);
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
sink->checkAllRead();
|
sink->checkAllRead();
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -146,8 +146,8 @@ try
|
|||||||
// WriteBufferFromOStream out(std::cout);
|
// WriteBufferFromOStream out(std::cout);
|
||||||
// printPipeline(processors, out);
|
// printPipeline(processors, out);
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
|
@ -261,8 +261,8 @@ try
|
|||||||
|
|
||||||
std::vector<ProcessorPtr> processors = {source, expanding, sink};
|
std::vector<ProcessorPtr> processors = {source, expanding, sink};
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
|
|
||||||
WriteBufferFromOStream out(std::cout);
|
WriteBufferFromOStream out(std::cout);
|
||||||
printPipeline(executor.getProcessors(), out);
|
printPipeline(executor.getProcessors(), out);
|
||||||
|
@ -303,8 +303,8 @@ try
|
|||||||
// WriteBufferFromOStream out(std::cout);
|
// WriteBufferFromOStream out(std::cout);
|
||||||
// printPipeline(processors, out);
|
// printPipeline(processors, out);
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
};
|
};
|
||||||
|
|
||||||
ThreadPool pool(4, 4, 10);
|
ThreadPool pool(4, 4, 10);
|
||||||
|
@ -140,8 +140,8 @@ try
|
|||||||
connect(transform->getOutputs().front(), sink->getPort());
|
connect(transform->getOutputs().front(), sink->getPort());
|
||||||
|
|
||||||
std::vector<ProcessorPtr> processors = {source, transform, sink};
|
std::vector<ProcessorPtr> processors = {source, transform, sink};
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
|
|
||||||
WriteBufferFromOStream out(std::cout);
|
WriteBufferFromOStream out(std::cout);
|
||||||
printPipeline(executor.getProcessors(), out);
|
printPipeline(executor.getProcessors(), out);
|
||||||
|
@ -176,8 +176,8 @@ try
|
|||||||
// WriteBufferFromOStream out(std::cout);
|
// WriteBufferFromOStream out(std::cout);
|
||||||
// printPipeline(processors, out);
|
// printPipeline(processors, out);
|
||||||
|
|
||||||
PipelineExecutor executor(processors, pool);
|
PipelineExecutor executor(processors);
|
||||||
executor.execute();
|
executor.execute(pool);
|
||||||
};
|
};
|
||||||
|
|
||||||
ThreadPool pool(4, 4, 10);
|
ThreadPool pool(4, 4, 10);
|
||||||
|
Loading…
Reference in New Issue
Block a user