contrib/clickhouse/src/Storages/ReadFinalForExternalReplicaStorage.h


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

#pragma once

#include "clickhouse_config.h"

#if USE_MYSQL || USE_LIBPQXX

#include <Storages/StorageProxy.h>
#include <QueryPipeline/Pipe.h>


namespace DB
{

bool needRewriteQueryWithFinalForStorage(const Names & column_names, const StoragePtr & storage);

void readFinalFromNestedStorage(
    QueryPlan & query_plan,
    StoragePtr nested_storage,
    const Names & column_names,
    SelectQueryInfo & query_info,
    ContextPtr context,
    QueryProcessingStage::Enum processed_stage,
    size_t max_block_size,
    size_t num_streams);

}

#endif