aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/serialize.cpp
diff options
context:
space:
mode:
authorermolovd <ermolovd@yandex-team.com>2024-11-26 15:38:34 +0300
committerermolovd <ermolovd@yandex-team.com>2024-11-26 15:52:27 +0300
commit0f8ebb5baf44e7aad96d0694c3148889b9a9d2b6 (patch)
tree591cefe9a40ded248b5efd92480ec8dcb33117b9 /yt/cpp/mapreduce/interface/serialize.cpp
parent2ab257cebc2f896cfe01f8bfb27ad34c644f93fe (diff)
downloadydb-0f8ebb5baf44e7aad96d0694c3148889b9a9d2b6.tar.gz
YT-23568: `create` attribute in RichYPath
* Changelog entry Type: feature Component: cpp-sdk Add support for `create` attribute in RichYPath. Don't create paths explicitly if `create` attribute is specified. commit_hash:52e77ce4cf5e21fae6d6e510ffb0edba35ec2a1d
Diffstat (limited to 'yt/cpp/mapreduce/interface/serialize.cpp')
-rw-r--r--yt/cpp/mapreduce/interface/serialize.cpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/serialize.cpp b/yt/cpp/mapreduce/interface/serialize.cpp
index 519439d879..5ea65b62f1 100644
--- a/yt/cpp/mapreduce/interface/serialize.cpp
+++ b/yt/cpp/mapreduce/interface/serialize.cpp
@@ -471,6 +471,9 @@ void Serialize(const TRichYPath& path, NYson::IYsonConsumer* consumer)
.DoIf(path.Cluster_.Defined(), [&] (TFluentAttributes fluent) {
fluent.Item("cluster").Value(*path.Cluster_);
})
+ .DoIf(path.Create_.Defined(), [&] (TFluentAttributes fluent) {
+ fluent.Item("create").Value(*path.Create_);
+ })
.EndAttributes()
.Value(path.Path_);
}
@@ -503,6 +506,7 @@ void Deserialize(TRichYPath& path, const TNode& node)
DESERIALIZE_ATTR("rename_columns", path.RenameColumns_);
DESERIALIZE_ATTR("bypass_artifact_cache", path.BypassArtifactCache_);
DESERIALIZE_ATTR("cluster", path.Cluster_);
+ DESERIALIZE_ATTR("create", path.Create_);
Deserialize(path.Path_, node);
}