diff options
Diffstat (limited to 'yt/cpp/mapreduce/io/yamr_table_reader.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/io/yamr_table_reader.cpp | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/io/yamr_table_reader.cpp b/yt/cpp/mapreduce/io/yamr_table_reader.cpp index 3ae6b8a8aeb..e9ebab520cc 100644 --- a/yt/cpp/mapreduce/io/yamr_table_reader.cpp +++ b/yt/cpp/mapreduce/io/yamr_table_reader.cpp @@ -78,6 +78,16 @@ bool TYaMRTableReader::IsRawReaderExhausted() const return TLenvalTableReader::IsRawReaderExhausted(); } +void TYaMRTableReader::Abort() +{ + Input_.Abort(); +} + +bool TYaMRTableReader::IsAborted() const +{ + return Input_.IsAborted(); +} + void TYaMRTableReader::ReadField(TString* result, i32 length) { result->resize(length); |
