diff options
author | whatsername <whatsername@yandex-team.com> | 2023-11-28 01:58:22 +0300 |
---|---|---|
committer | whatsername <whatsername@yandex-team.com> | 2023-11-28 02:23:57 +0300 |
commit | 81a61c738d42a24ad014cecaf6d9136b7bbd8e6e (patch) | |
tree | 4330b01a5dc0fe57a3c532eeb467300464e9b029 /yt/cpp/mapreduce/io/proto_table_reader.h | |
parent | c62e64752b2c70d7a81a42c24d38cfa6a0950a78 (diff) | |
download | ydb-81a61c738d42a24ad014cecaf6d9136b7bbd8e6e.tar.gz |
ROREN-48: Support multi table proto read
Diffstat (limited to 'yt/cpp/mapreduce/io/proto_table_reader.h')
-rw-r--r-- | yt/cpp/mapreduce/io/proto_table_reader.h | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/io/proto_table_reader.h b/yt/cpp/mapreduce/io/proto_table_reader.h index 05a528b9c6..8452545005 100644 --- a/yt/cpp/mapreduce/io/proto_table_reader.h +++ b/yt/cpp/mapreduce/io/proto_table_reader.h @@ -18,7 +18,7 @@ public: explicit TProtoTableReader( ::TIntrusivePtr<TRawTableReader> input, TVector<const ::google::protobuf::Descriptor*>&& descriptors); - ~TProtoTableReader() override; + ~TProtoTableReader() override = default; void ReadRow(Message* row) override; @@ -47,7 +47,11 @@ public: explicit TLenvalProtoTableReader( ::TIntrusivePtr<TRawTableReader> input, TVector<const ::google::protobuf::Descriptor*>&& descriptors); - ~TLenvalProtoTableReader() override; + + explicit TLenvalProtoTableReader( + ::TIntrusivePtr<TRawTableReader> input); + + ~TLenvalProtoTableReader() override = default; void ReadRow(Message* row) override; @@ -65,6 +69,7 @@ protected: void SkipRow() override; private: + bool ValidateProtoDescriptor_; TVector<const ::google::protobuf::Descriptor*> Descriptors_; }; |