thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use opd prewhere optimizaer for old analyzer.

Browse Source
This commit is contained in:
Nikolai Kochetov 2024-02-09 14:47:24 +00:00
parent 7575f0db84
commit 1063d9ca50
1 changed files with 28 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
src/Interpreters/InterpreterSelectQuery.cpp
View File

@ -600,7 +600,7 @@ InterpreterSelectQuery::InterpreterSelectQuery(
query.setFinal();
}
auto analyze = [&] (bool)
auto analyze = [&] (bool try_move_to_prewhere)
{
/// Allow push down and other optimizations for VIEW: replace with subquery and rewrite it.
ASTPtr view_table;
@ -632,37 +632,37 @@ InterpreterSelectQuery::InterpreterSelectQuery(
view = nullptr;
}
// if (try_move_to_prewhere
// && storage && storage->canMoveConditionsToPrewhere()
// && query.where() && !query.prewhere()
// && !query.hasJoin()) /// Join may produce rows with nulls or default values, it's difficult to analyze if they affected or not.
// {
// /// PREWHERE optimization: transfer some condition from WHERE to PREWHERE if enabled and viable
// if (const auto & column_sizes = storage->getColumnSizes(); !column_sizes.empty())
// {
// /// Extract column compressed sizes.
// std::unordered_map<std::string, UInt64> column_compressed_sizes;
// for (const auto & [name, sizes] : column_sizes)
// column_compressed_sizes[name] = sizes.data_compressed;
if (try_move_to_prewhere
&& storage && storage->canMoveConditionsToPrewhere()
&& query.where() && !query.prewhere()
&& !query.hasJoin()) /// Join may produce rows with nulls or default values, it's difficult to analyze if they affected or not.
{
/// PREWHERE optimization: transfer some condition from WHERE to PREWHERE if enabled and viable
if (const auto & column_sizes = storage->getColumnSizes(); !column_sizes.empty())
{
/// Extract column compressed sizes.
std::unordered_map<std::string, UInt64> column_compressed_sizes;
for (const auto & [name, sizes] : column_sizes)
column_compressed_sizes[name] = sizes.data_compressed;
// SelectQueryInfo current_info;
// current_info.query = query_ptr;
// current_info.syntax_analyzer_result = syntax_analyzer_result;
SelectQueryInfo current_info;
current_info.query = query_ptr;
current_info.syntax_analyzer_result = syntax_analyzer_result;
// Names queried_columns = syntax_analyzer_result->requiredSourceColumns();
// const auto & supported_prewhere_columns = storage->supportedPrewhereColumns();
Names queried_columns = syntax_analyzer_result->requiredSourceColumns();
const auto & supported_prewhere_columns = storage->supportedPrewhereColumns();
// MergeTreeWhereOptimizer where_optimizer{
// std::move(column_compressed_sizes),
// metadata_snapshot,
// storage->getConditionEstimatorByPredicate(query_info, storage_snapshot, context),
// queried_columns,
// supported_prewhere_columns,
// log};
MergeTreeWhereOptimizer where_optimizer{
std::move(column_compressed_sizes),
metadata_snapshot,
storage->getConditionEstimatorByPredicate(query_info, storage_snapshot, context),
queried_columns,
supported_prewhere_columns,
log};
// where_optimizer.optimize(current_info, context);
// }
// }
where_optimizer.optimize(current_info, context);
}
}
if (query.prewhere() && query.where())
{