summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/interface/raw_client.h
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-18 17:25:58 +0300
committerhiddenpath <[email protected]>2024-12-18 17:44:47 +0300
commit492fb432bf89c4b16548b9cc215d0cb4e39c7b83 (patch)
tree7da4b45be23fcceeb5ea7ddc2cd962dd74a6c42c /yt/cpp/mapreduce/interface/raw_client.h
parentda0030f3cb73ddbbfc27f8dc404ba382b32bd60d (diff)
[yt/cpp/mapreduce] YT-23616: Move Transaction, Misc, Table methods to THttpRawClient
commit_hash:a08daac218b8d8bbd805220429b62f2284ad094f
Diffstat (limited to 'yt/cpp/mapreduce/interface/raw_client.h')
-rw-r--r--yt/cpp/mapreduce/interface/raw_client.h75
1 files changed, 74 insertions, 1 deletions
diff --git a/yt/cpp/mapreduce/interface/raw_client.h b/yt/cpp/mapreduce/interface/raw_client.h
index 5a11a9f9603..32055e3d004 100644
--- a/yt/cpp/mapreduce/interface/raw_client.h
+++ b/yt/cpp/mapreduce/interface/raw_client.h
@@ -115,7 +115,20 @@ public:
// Transactions
- virtual void PingTx(const TTransactionId& transactionId) = 0;
+ virtual TTransactionId StartTransaction(
+ TMutationId& mutationId,
+ const TTransactionId& parentId,
+ const TStartTransactionOptions& options = {}) = 0;
+
+ virtual void PingTransaction(const TTransactionId& transactionId) = 0;
+
+ virtual void AbortTransaction(
+ TMutationId& mutationId,
+ const TTransactionId& transactionId) = 0;
+
+ virtual void CommitTransaction(
+ TMutationId& mutationId,
+ const TTransactionId& transactionId) = 0;
// Operations
@@ -183,6 +196,21 @@ public:
const TOperationId& operationId,
const TGetJobTraceOptions& options = {}) = 0;
+ // File cache
+
+ virtual TMaybe<TYPath> GetFileFromCache(
+ const TTransactionId& transactionId,
+ const TString& md5Signature,
+ const TYPath& cachePath,
+ const TGetFileFromCacheOptions& options = {}) = 0;
+
+ virtual TYPath PutFileToCache(
+ const TTransactionId& transactionId,
+ const TYPath& filePath,
+ const TString& md5Signature,
+ const TYPath& cachePath,
+ const TPutFileToCacheOptions& options = {}) = 0;
+
// Tables
virtual void MountTable(
@@ -232,8 +260,53 @@ public:
const TString& query,
const TSelectRowsOptions& options = {}) = 0;
+ virtual void AlterTable(
+ TMutationId& mutationId,
+ const TTransactionId& transactionId,
+ const TYPath& path,
+ const TAlterTableOptions& options = {}) = 0;
+
+ virtual void AlterTableReplica(
+ TMutationId& mutationId,
+ const TReplicaId& replicaId,
+ const TAlterTableReplicaOptions& options = {}) = 0;
+
+ virtual void DeleteRows(
+ const TYPath& path,
+ const TNode::TListType& keys,
+ const TDeleteRowsOptions& options = {}) = 0;
+
+ virtual void FreezeTable(
+ const TYPath& path,
+ const TFreezeTableOptions& options = {}) = 0;
+
+ virtual void UnfreezeTable(
+ const TYPath& path,
+ const TUnfreezeTableOptions& options = {}) = 0;
+
// Misc
+ virtual TCheckPermissionResponse CheckPermission(
+ const TString& user,
+ EPermission permission,
+ const TYPath& path,
+ const TCheckPermissionOptions& options = {}) = 0;
+
+ virtual TVector<TTabletInfo> GetTabletInfos(
+ const TYPath& path,
+ const TVector<int>& tabletIndexes,
+ const TGetTabletInfosOptions& options = {}) = 0;
+
+ virtual TVector<TTableColumnarStatistics> GetTableColumnarStatistics(
+ const TTransactionId& transactionId,
+ const TVector<TRichYPath>& paths,
+ const TGetTableColumnarStatisticsOptions& options = {}) = 0;
+
+ virtual TMultiTablePartitions GetTablePartitions(
+ const TTransactionId& transactionId,
+ const TVector<TRichYPath>& paths,
+ const TGetTablePartitionsOptions& options = {}) = 0;
+
virtual ui64 GenerateTimestamp() = 0;
virtual TAuthorizationInfo WhoAmI() = 0;