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/interface/raw_client.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/interface/raw_client.h')
| -rw-r--r-- | yt/cpp/mapreduce/interface/raw_client.h | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h index e318c022ce5..9347a95e6e6 100644 --- a/yt/cpp/mapreduce/interface/raw_client.h +++ b/yt/cpp/mapreduce/interface/raw_client.h @@ -4,6 +4,8 @@ #include "client_method_options.h" #include "operation.h" +#include <yt/cpp/mapreduce/interface/abortable_stream.h> + #include <yt/cpp/mapreduce/http/context.h> namespace NYT { @@ -213,7 +215,7 @@ public: // Files - virtual std::unique_ptr<IInputStream> ReadFile( + virtual std::unique_ptr<IAbortableInputStream> ReadFile( const TTransactionId& transactionId, const TRichYPath& path, const TFileReaderOptions& options = {}) = 0; @@ -299,18 +301,18 @@ public: const TMaybe<TFormat>& format, const TTableWriterOptions& options = {}) = 0; - virtual std::unique_ptr<IInputStream> ReadTable( + virtual std::unique_ptr<IAbortableInputStream> ReadTable( const TTransactionId& transactionId, const TRichYPath& path, const TFormat& format, const TTableReaderOptions& options = {}) = 0; - virtual std::unique_ptr<IInputStream> ReadTablePartition( + virtual std::unique_ptr<IAbortableInputStream> ReadTablePartition( const TString& cookie, const TFormat& format, const TTablePartitionReaderOptions& options = {}) = 0; - virtual std::unique_ptr<IInputStream> ReadBlobTable( + virtual std::unique_ptr<IAbortableInputStream> ReadBlobTable( const TTransactionId& transactionId, const TRichYPath& path, const TKey& key, |
