diff options
author | hiddenpath <[email protected]> | 2024-12-18 17:25:58 +0300 |
---|---|---|
committer | hiddenpath <[email protected]> | 2024-12-18 17:44:47 +0300 |
commit | 492fb432bf89c4b16548b9cc215d0cb4e39c7b83 (patch) | |
tree | 7da4b45be23fcceeb5ea7ddc2cd962dd74a6c42c /yt/cpp/mapreduce/interface/raw_client.h | |
parent | da0030f3cb73ddbbfc27f8dc404ba382b32bd60d (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.h | 75 |
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; |