blob: 65fab6035b14b5a24910bebe67d3c628c353f1bd (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
#pragma once
#include <functional>
#include <memory>
namespace DB
{
class QueryPipeline;
/// Executor for completed QueryPipeline.
/// Allows to specify a callback which checks if execution should be cancelled.
/// If callback is specified, runs execution in a separate thread.
class CompletedPipelineExecutor
{
public:
explicit CompletedPipelineExecutor(QueryPipeline & pipeline_);
~CompletedPipelineExecutor();
/// This callback will be called each interactive_timeout_ms (if it is not 0).
/// If returns true, query would be cancelled.
void setCancelCallback(std::function<bool()> is_cancelled, size_t interactive_timeout_ms_);
void execute();
struct Data;
private:
QueryPipeline & pipeline;
std::function<bool()> is_cancelled_callback;
size_t interactive_timeout_ms = 0;
std::unique_ptr<Data> data;
};
}
|
