aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2024-02-07 11:47:25 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2024-02-07 12:03:53 +0300
commit45c9080cd82392b6e4bc97b80daa04eb87fb5b29 (patch)
treed8266960b372f8d3661037cef0ca83223a68672a /yt/cpp
parent3139d9ab6df2a7014d19b87582466d17b4f496e2 (diff)
downloadydb-45c9080cd82392b6e4bc97b80daa04eb87fb5b29.tar.gz
Intermediate changes
Diffstat (limited to 'yt/cpp')
-rw-r--r--yt/cpp/mapreduce/io/skiff_table_reader.cpp7
1 files changed, 3 insertions, 4 deletions
diff --git a/yt/cpp/mapreduce/io/skiff_table_reader.cpp b/yt/cpp/mapreduce/io/skiff_table_reader.cpp
index 66c7c3ab6f..3f6440a8bb 100644
--- a/yt/cpp/mapreduce/io/skiff_table_reader.cpp
+++ b/yt/cpp/mapreduce/io/skiff_table_reader.cpp
@@ -180,10 +180,9 @@ TVector<TSkiffTableReader::TSkiffTableSchema> TSkiffTableReader::CreateSkiffTabl
"Expected 'tuple' wire type for table schema, got '" << tableSchema->GetWireType() << "'");
TVector<TSkiffColumnSchema> columns;
for (const auto& columnSchema : tableSchema->GetChildren()) {
- if (columnSchema->GetName().StartsWith("$")) {
- auto iter = specialColumns.find(columnSchema->GetName());
- Y_ENSURE(iter != specialColumns.end(), "Unknown special column: " << columnSchema->GetName());
- columns.push_back(iter->second);
+ auto specialColumnIter = specialColumns.find(columnSchema->GetName());
+ if (specialColumnIter != specialColumns.end()) {
+ columns.push_back(specialColumnIter->second);
} else {
auto wireType = columnSchema->GetWireType();
bool required = true;