diff options
| author | lucius <[email protected]> | 2025-10-22 11:00:50 +0300 |
|---|---|---|
| committer | lucius <[email protected]> | 2025-10-22 11:36:24 +0300 |
| commit | a3ff6b1f20b37a7ce6790aaf9841d2780800cf56 (patch) | |
| tree | 7dc6e3b224b1ce23391337cf721f89240ac349fd /yt/cpp/mapreduce/interface/serialize.cpp | |
| parent | ee97459a5fb2a1b11f1094e092bb9efdd2e5e6c5 (diff) | |
YT-26213: Per table input_query (chunk_filter only)
Сейчас поддерживается только режим chunk\_filter (ровно он нужен сейчас для оптимизаторов в yql), а row\_filter можно будет поддержать в будущем.
<Message NOT for release notes>
* Changelog entry
Type: feature
Component: controller-agent
Introduce chunk filtration via `input_query` in path attributes. Useful for read optimizations.
commit_hash:575c384f3156e57e692d4a05c9b50a54ad0fa377
Diffstat (limited to 'yt/cpp/mapreduce/interface/serialize.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/interface/serialize.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/serialize.cpp b/yt/cpp/mapreduce/interface/serialize.cpp index 28a734a500b..44e168704d7 100644 --- a/yt/cpp/mapreduce/interface/serialize.cpp +++ b/yt/cpp/mapreduce/interface/serialize.cpp @@ -482,6 +482,9 @@ void Serialize(const TRichYPath& path, NYson::IYsonConsumer* consumer) .DoIf(path.Create_.Defined(), [&] (TFluentAttributes fluent) { fluent.Item("create").Value(*path.Create_); }) + .DoIf(path.InputQuery_.Defined(), [&] (TFluentAttributes fluent) { + fluent.Item("input_query").Value(*path.InputQuery_); + }) .EndAttributes() .Value(path.Path_); } @@ -515,6 +518,7 @@ void Deserialize(TRichYPath& path, const TNode& node) DESERIALIZE_ATTR("bypass_artifact_cache", path.BypassArtifactCache_); DESERIALIZE_ATTR("cluster", path.Cluster_); DESERIALIZE_ATTR("create", path.Create_); + DESERIALIZE_ATTR("input_query", path.InputQuery_); Deserialize(path.Path_, node); } |