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
|
#pragma once
#include <Core/Defines.h>
#include <Core/BaseSettings.h>
namespace DB
{
class ASTStorage;
#define LIST_OF_EXECUTABLE_SETTINGS(M, ALIAS) \
M(Bool, send_chunk_header, false, "Send number_of_rows\n before sending chunk to process.", 0) \
M(UInt64, pool_size, 16, "Processes pool size. If size == 0, then there is no size restrictions.", 0) \
M(UInt64, max_command_execution_time, 10, "Max command execution time in seconds.", 0) \
M(UInt64, command_termination_timeout, 10, "Command termination timeout in seconds.", 0) \
M(UInt64, command_read_timeout, 10000, "Timeout for reading data from command stdout in milliseconds.", 0) \
M(UInt64, command_write_timeout, 10000, "Timeout for writing data to command stdin in milliseconds.", 0) \
M(ExternalCommandStderrReaction, stderr_reaction, ExternalCommandStderrReaction::NONE, "Reaction when external command outputs data to its stderr.", 0) \
M(Bool, check_exit_code, false, "Throw exception if the command exited with non-zero status code.", 0) \
DECLARE_SETTINGS_TRAITS(ExecutableSettingsTraits, LIST_OF_EXECUTABLE_SETTINGS)
/// Settings for ExecutablePool engine.
struct ExecutableSettings : public BaseSettings<ExecutableSettingsTraits>
{
std::string script_name;
std::vector<std::string> script_arguments;
bool is_executable_pool = false;
void loadFromQuery(ASTStorage & storage_def);
};
}
|
