aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@ydb.tech>2023-09-29 01:37:49 +0300
committeraozeritsky <aozeritsky@ydb.tech>2023-09-29 01:56:33 +0300
commit988fafb649de5d5b5b4d4c5335a087441c6763f4 (patch)
tree6de2e272376b23e79ae308f9ff77e13f3c812273
parentf5f10c72b47a362fcf641902cca19acd406dd6ab (diff)
downloadydb-988fafb649de5d5b5b4d4c5335a087441c6763f4.tar.gz
Fill cost field in TOptimizerStatistics
-rw-r--r--ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp2
-rw-r--r--ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp1
2 files changed, 2 insertions, 1 deletions
diff --git a/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp b/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp
index 112999eaa35..a008d96d1a6 100644
--- a/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp
+++ b/ydb/library/yql/providers/s3/provider/yql_s3_dq_integration.cpp
@@ -154,7 +154,7 @@ public:
}
rows = size / 1024; // magic estimate
- return TOptimizerStatistics(rows, cols);
+ return TOptimizerStatistics(rows, cols, size);
} else {
return Nothing();
}
diff --git a/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp b/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp
index 896200ced60..8f54076f94b 100644
--- a/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp
+++ b/ydb/library/yql/providers/yt/provider/yql_yt_dq_integration.cpp
@@ -364,6 +364,7 @@ public:
}
}
}
+ stat.Cost = stat.Nrows * std::max(stat.Ncols, 1);
return stat;
}