summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/http_client/raw_client.cpp
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/http_client/raw_client.cpp
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/http_client/raw_client.cpp')
-rw-r--r--yt/cpp/mapreduce/http_client/raw_client.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/yt/cpp/mapreduce/http_client/raw_client.cpp b/yt/cpp/mapreduce/http_client/raw_client.cpp
index 4ccafb1a987..557e4afdbd4 100644
--- a/yt/cpp/mapreduce/http_client/raw_client.cpp
+++ b/yt/cpp/mapreduce/http_client/raw_client.cpp
@@ -632,7 +632,7 @@ IFileReaderPtr THttpRawClient::GetJobTrace(
return MakeIntrusive<NHttpClient::THttpResponseStream>(std::move(responseInfo));
}
-std::unique_ptr<IInputStream> THttpRawClient::ReadFile(
+std::unique_ptr<IAbortableInputStream> THttpRawClient::ReadFile(
const TTransactionId& transactionId,
const TRichYPath& path,
const TFileReaderOptions& options)
@@ -827,7 +827,7 @@ std::unique_ptr<IOutputStream> THttpRawClient::WriteTable(
return NRawClient::WriteTable(Context_, transactionId, path, format, options);
}
-std::unique_ptr<IInputStream> THttpRawClient::ReadTable(
+std::unique_ptr<IAbortableInputStream> THttpRawClient::ReadTable(
const TTransactionId& transactionId,
const TRichYPath& path,
const TFormat& format,
@@ -854,7 +854,7 @@ std::unique_ptr<IOutputStream> THttpRawClient::WriteFile(
return NRawClient::WriteFile(Context_, transactionId, path, options);
}
-std::unique_ptr<IInputStream> THttpRawClient::ReadTablePartition(
+std::unique_ptr<IAbortableInputStream> THttpRawClient::ReadTablePartition(
const TString& cookie,
const TFormat& format,
const TTablePartitionReaderOptions& options)
@@ -872,7 +872,7 @@ std::unique_ptr<IInputStream> THttpRawClient::ReadTablePartition(
return std::make_unique<NHttpClient::THttpResponseStream>(std::move(responseInfo));
}
-std::unique_ptr<IInputStream> THttpRawClient::ReadBlobTable(
+std::unique_ptr<IAbortableInputStream> THttpRawClient::ReadBlobTable(
const TTransactionId& transactionId,
const TRichYPath& path,
const TKey& key,