diff options
| author | orlovorlov <orlovorlov@yandex-team.com> | 2023-11-22 14:05:04 +0300 |
|---|---|---|
| committer | orlovorlov <orlovorlov@yandex-team.com> | 2023-11-22 17:14:06 +0300 |
| commit | 0adff98ae52cb826f7fb9705503e430b9812994f (patch) | |
| tree | 72c2ba4759a49c256e383c68539e35643e0360d6 /yt/cpp/mapreduce/interface/serialize.cpp | |
| parent | ab6222f2deabf1a12b50db13728b68cbd6b59604 (diff) | |
| download | ydb-0adff98ae52cb826f7fb9705503e430b9812994f.tar.gz | |
YT-18863 Support 'deleted' field in NYT::TTableSchema
Diffstat (limited to 'yt/cpp/mapreduce/interface/serialize.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/interface/serialize.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/serialize.cpp b/yt/cpp/mapreduce/interface/serialize.cpp index 8557985069..7cd8417487 100644 --- a/yt/cpp/mapreduce/interface/serialize.cpp +++ b/yt/cpp/mapreduce/interface/serialize.cpp @@ -246,6 +246,12 @@ void Serialize(const TColumnSchema& columnSchema, NYson::IYsonConsumer* consumer .DoIf(columnSchema.Group().Defined(), [&] (TFluentMap fluent) { fluent.Item("group").Value(*columnSchema.Group()); }) + .DoIf(columnSchema.StableName().Defined(), [&] (TFluentMap fluent) { + fluent.Item("stable_name").Value(*columnSchema.StableName()); + }) + .DoIf(columnSchema.Deleted().Defined(), [&] (TFluentMap fluent) { + fluent.Item("deleted").Value(*columnSchema.Deleted()); + }) .EndMap(); } @@ -259,6 +265,8 @@ void Deserialize(TColumnSchema& columnSchema, const TNode& node) DESERIALIZE_ITEM("expression", columnSchema.Expression_); DESERIALIZE_ITEM("aggregate", columnSchema.Aggregate_); DESERIALIZE_ITEM("group", columnSchema.Group_); + DESERIALIZE_ITEM("stable_name", columnSchema.StableName_); + DESERIALIZE_ITEM("deleted", columnSchema.Deleted_); if (nodeMap.contains("type_v3")) { NTi::TTypePtr type; |