diff options
| author | maybenotilya <[email protected]> | 2026-04-17 11:57:44 +0300 |
|---|---|---|
| committer | maybenotilya <[email protected]> | 2026-04-17 12:34:55 +0300 |
| commit | a6423bf330c10089d7a0e2aaa8d971d0dcbb3fcf (patch) | |
| tree | 087131eb0146a82cd9c72d1b0a290d8d081c021e /yt/cpp/mapreduce/io/node_table_reader.h | |
| parent | 7bcfb91453e538211ed44e97c57d1104f543f920 (diff) | |
YT-26179: Add Abort for readers
* Changelog entry
Type: feature
Component: cpp-sdk
Add Abort for table readers
commit_hash:be5026883c90d18333f20468946f1e5a5b71839b
Diffstat (limited to 'yt/cpp/mapreduce/io/node_table_reader.h')
| -rw-r--r-- | yt/cpp/mapreduce/io/node_table_reader.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/io/node_table_reader.h b/yt/cpp/mapreduce/io/node_table_reader.h index c8e319ce4f6..92af5b111b2 100644 --- a/yt/cpp/mapreduce/io/node_table_reader.h +++ b/yt/cpp/mapreduce/io/node_table_reader.h @@ -11,8 +11,6 @@ #include <util/system/event.h> #include <util/system/thread.h> -#include <atomic> - namespace NYT { class TRawTableReader; @@ -54,6 +52,8 @@ public: TMaybe<size_t> GetReadByteCount() const override; bool IsEndOfStream() const override; bool IsRawReaderExhausted() const override; + void Abort() override; + bool IsAborted() const override; private: void NextImpl(); |