aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/raw_client.h
diff options
context:
space:
mode:
authorAlexander Smirnov <alex@ydb.tech>2024-12-24 15:46:17 +0000
committerAlexander Smirnov <alex@ydb.tech>2024-12-24 15:46:17 +0000
commitc7decaf9230ddcb1ec2c42d1f50fb3998166c4ef (patch)
tree4efde4e4276bb0f24c314909403a1f6ed94c60d7 /yt/cpp/mapreduce/interface/raw_client.h
parentcf344b64297e6a79d1e538be9f8f59afb06a2a97 (diff)
parentb821606f7bd364dc755d37b5bcb3559130675364 (diff)
downloadydb-c7decaf9230ddcb1ec2c42d1f50fb3998166c4ef.tar.gz
Merge branch 'rightlib' into merge-libs-241224-1545
Diffstat (limited to 'yt/cpp/mapreduce/interface/raw_client.h')
-rw-r--r--yt/cpp/mapreduce/interface/raw_client.h31
1 files changed, 31 insertions, 0 deletions
diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h
index 32055e3d00..4994826863 100644
--- a/yt/cpp/mapreduce/interface/raw_client.h
+++ b/yt/cpp/mapreduce/interface/raw_client.h
@@ -8,6 +8,13 @@ namespace NYT {
////////////////////////////////////////////////////////////////////////////////
+namespace NHttpClient {
+ class IHttpResponse;
+ using IHttpResponsePtr = std::unique_ptr<IHttpResponse>;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+
class IRawClient
: public virtual TThrRefBase
{
@@ -196,6 +203,18 @@ public:
const TOperationId& operationId,
const TGetJobTraceOptions& options = {}) = 0;
+ // SkyShare
+
+ virtual NHttpClient::IHttpResponsePtr SkyShareTable(
+ const std::vector<TYPath>& tablePaths,
+ const TSkyShareTableOptions& options = {}) = 0;
+
+ // Files
+ virtual std::unique_ptr<IInputStream> ReadFile(
+ const TTransactionId& transactionId,
+ const TRichYPath& path,
+ const TFileReaderOptions& options = {}) = 0;
+
// File cache
virtual TMaybe<TYPath> GetFileFromCache(
@@ -266,6 +285,18 @@ public:
const TYPath& path,
const TAlterTableOptions& options = {}) = 0;
+ virtual std::unique_ptr<IInputStream> ReadTable(
+ const TTransactionId& transactionId,
+ const TRichYPath& path,
+ const TMaybe<TFormat>& format,
+ const TTableReaderOptions& options = {}) = 0;
+
+ virtual std::unique_ptr<IInputStream> ReadBlobTable(
+ const TTransactionId& transactionId,
+ const TRichYPath& path,
+ const TKey& key,
+ const TBlobTableReaderOptions& options = {}) = 0;
+
virtual void AlterTableReplica(
TMutationId& mutationId,
const TReplicaId& replicaId,