aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--yt/cpp/mapreduce/interface/common.h3
-rw-r--r--yt/cpp/mapreduce/interface/serialize.cpp1
2 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/common.h b/yt/cpp/mapreduce/interface/common.h
index 49e01bad55..10988225dd 100644
--- a/yt/cpp/mapreduce/interface/common.h
+++ b/yt/cpp/mapreduce/interface/common.h
@@ -1193,6 +1193,9 @@ struct TTableColumnarStatistics
/// Total data weight for all chunks for each of requested columns.
THashMap<TString, i64> ColumnDataWeight;
+ /// Estimated number of unique elements for each column.
+ THashMap<TString, ui64> ColumnEstimatedUniqueCounts;
+
/// Total weight of all old chunks that don't keep columnar statistics.
i64 LegacyChunksDataWeight = 0;
diff --git a/yt/cpp/mapreduce/interface/serialize.cpp b/yt/cpp/mapreduce/interface/serialize.cpp
index 9be114b45e..b195bf04d6 100644
--- a/yt/cpp/mapreduce/interface/serialize.cpp
+++ b/yt/cpp/mapreduce/interface/serialize.cpp
@@ -509,6 +509,7 @@ void Deserialize(TTableColumnarStatistics& statistics, const TNode& node)
{
const auto& nodeMap = node.AsMap();
DESERIALIZE_ITEM("column_data_weights", statistics.ColumnDataWeight);
+ DESERIALIZE_ITEM("column_estimated_unique_counts", statistics.ColumnEstimatedUniqueCounts);
DESERIALIZE_ITEM("legacy_chunks_data_weight", statistics.LegacyChunksDataWeight);
DESERIALIZE_ITEM("timestamp_total_weight", statistics.TimestampTotalWeight);
}