diff options
author | robot-piglet <robot-piglet@yandex-team.com> | 2024-02-07 11:47:25 +0300 |
---|---|---|
committer | robot-piglet <robot-piglet@yandex-team.com> | 2024-02-07 12:03:53 +0300 |
commit | 45c9080cd82392b6e4bc97b80daa04eb87fb5b29 (patch) | |
tree | d8266960b372f8d3661037cef0ca83223a68672a /yt/cpp | |
parent | 3139d9ab6df2a7014d19b87582466d17b4f496e2 (diff) | |
download | ydb-45c9080cd82392b6e4bc97b80daa04eb87fb5b29.tar.gz |
Intermediate changes
Diffstat (limited to 'yt/cpp')
-rw-r--r-- | yt/cpp/mapreduce/io/skiff_table_reader.cpp | 7 |
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; |