diff options
author | Alexander Smirnov <alex@ydb.tech> | 2024-12-24 15:46:17 +0000 |
---|---|---|
committer | Alexander Smirnov <alex@ydb.tech> | 2024-12-24 15:46:17 +0000 |
commit | c7decaf9230ddcb1ec2c42d1f50fb3998166c4ef (patch) | |
tree | 4efde4e4276bb0f24c314909403a1f6ed94c60d7 /yt/cpp/mapreduce/interface/raw_client.h | |
parent | cf344b64297e6a79d1e538be9f8f59afb06a2a97 (diff) | |
parent | b821606f7bd364dc755d37b5bcb3559130675364 (diff) | |
download | ydb-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.h | 31 |
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, |