diff options
| author | hiddenpath <[email protected]> | 2024-12-13 15:22:36 +0300 |
|---|---|---|
| committer | hiddenpath <[email protected]> | 2024-12-13 17:04:18 +0300 |
| commit | 09c88b035d29fac5fd49de2fbc3c71e2d2a80754 (patch) | |
| tree | a84b5b2de4dcdf85c3b22b9cac7e984aebb8b68d /yt/cpp/mapreduce/raw_client/raw_requests.cpp | |
| parent | 615edba542d9394b0eae47ef957ec2257549cfdd (diff) | |
yt/cpp/mapreduce: move Get, TryGet, Exists, MultisetAttributes to THttpRawClient
commit_hash:bd2228f98fa92de408ca850f9bc1608fdf99e7f5
Diffstat (limited to 'yt/cpp/mapreduce/raw_client/raw_requests.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/raw_client/raw_requests.cpp | 57 |
1 files changed, 0 insertions, 57 deletions
diff --git a/yt/cpp/mapreduce/raw_client/raw_requests.cpp b/yt/cpp/mapreduce/raw_client/raw_requests.cpp index d10c818489c..13100a29070 100644 --- a/yt/cpp/mapreduce/raw_client/raw_requests.cpp +++ b/yt/cpp/mapreduce/raw_client/raw_requests.cpp @@ -79,35 +79,6 @@ void ExecuteBatch( } } -TNode Get( - const IRequestRetryPolicyPtr& retryPolicy, - const TClientContext& context, - const TTransactionId& transactionId, - const TYPath& path, - const TGetOptions& options) -{ - THttpHeader header("GET", "get"); - header.MergeParameters(SerializeParamsForGet(transactionId, context.Config->Prefix, path, options)); - return NodeFromYsonString(RetryRequestWithPolicy(retryPolicy, context, header).Response); -} - -TNode TryGet( - const IRequestRetryPolicyPtr& retryPolicy, - const TClientContext& context, - const TTransactionId& transactionId, - const TYPath& path, - const TGetOptions& options) -{ - try { - return Get(retryPolicy, context, transactionId, path, options); - } catch (const TErrorResponse& error) { - if (!error.IsResolveError()) { - throw; - } - return TNode(); - } -} - void Set( const IRequestRetryPolicyPtr& retryPolicy, const TClientContext& context, @@ -123,34 +94,6 @@ void Set( RetryRequestWithPolicy(retryPolicy, context, header, body); } -void MultisetAttributes( - const IRequestRetryPolicyPtr& retryPolicy, - const TClientContext& context, - const TTransactionId& transactionId, - const TYPath& path, - const TNode::TMapType& value, - const TMultisetAttributesOptions& options) -{ - THttpHeader header("PUT", "api/v4/multiset_attributes", false); - header.AddMutationId(); - header.MergeParameters(SerializeParamsForMultisetAttributes(transactionId, context.Config->Prefix, path, options)); - - auto body = NodeToYsonString(value); - RetryRequestWithPolicy(retryPolicy, context, header, body); -} - -bool Exists( - const IRequestRetryPolicyPtr& retryPolicy, - const TClientContext& context, - const TTransactionId& transactionId, - const TYPath& path, - const TExistsOptions& options) -{ - THttpHeader header("GET", "exists"); - header.MergeParameters(SerializeParamsForExists(transactionId, context.Config->Prefix, path, options)); - return ParseBoolFromResponse(RetryRequestWithPolicy(retryPolicy, context, header).Response); -} - TNodeId Create( const IRequestRetryPolicyPtr& retryPolicy, const TClientContext& context, |
