summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/raw_client.h
diff options
context:
space:
mode:
authormaybenotilya <[email protected]>2026-04-17 11:57:44 +0300
committermaybenotilya <[email protected]>2026-04-17 12:34:55 +0300
commita6423bf330c10089d7a0e2aaa8d971d0dcbb3fcf (patch)
tree087131eb0146a82cd9c72d1b0a290d8d081c021e /yt/cpp/mapreduce/interface/raw_client.h
parent7bcfb91453e538211ed44e97c57d1104f543f920 (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.h10
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,