summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/io/counting_raw_reader.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'yt/cpp/mapreduce/io/counting_raw_reader.cpp')
-rw-r--r--yt/cpp/mapreduce/io/counting_raw_reader.cpp10
1 files changed, 10 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/io/counting_raw_reader.cpp b/yt/cpp/mapreduce/io/counting_raw_reader.cpp
index c6213e86651..05f3b1cca6b 100644
--- a/yt/cpp/mapreduce/io/counting_raw_reader.cpp
+++ b/yt/cpp/mapreduce/io/counting_raw_reader.cpp
@@ -28,6 +28,16 @@ size_t TCountingRawTableReader::GetReadByteCount() const
return ReadByteCount_;
}
+void TCountingRawTableReader::Abort()
+{
+ Reader_->Abort();
+}
+
+bool TCountingRawTableReader::IsAborted() const
+{
+ return Reader_->IsAborted();
+}
+
size_t TCountingRawTableReader::DoRead(void* buf, size_t len)
{
auto readLen = Reader_->Read(buf, len);