summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/yamr_table_reader.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/io/yamr_table_reader.cpp')
-rw-r--r--yt/cpp/mapreduce/io/yamr_table_reader.cpp10
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);