diff options
| author | max42 <[email protected]> | 2023-06-30 11:13:34 +0300 |
|---|---|---|
| committer | max42 <[email protected]> | 2023-06-30 11:13:34 +0300 |
| commit | 3e1899838408bbad47622007aa382bc8a2b01f87 (patch) | |
| tree | 0f21c1e6add187ddb6c3ccc048a7d640ce03fb87 /yt/cpp/mapreduce/client/batch_request_impl.cpp | |
| parent | 5463eb3f5e72a86f858a3d27c886470a724ede34 (diff) | |
Revert "YT-19324: move YT provider to ydb/library/yql"
This reverts commit ca272f12fdd0e8d5c3e957fc87939148f1caaf72, reversing
changes made to 49f8acfc8b0b5c0071b804423bcf53fda26c7c12.
Diffstat (limited to 'yt/cpp/mapreduce/client/batch_request_impl.cpp')
| -rw-r--r-- | yt/cpp/mapreduce/client/batch_request_impl.cpp | 198 |
1 files changed, 0 insertions, 198 deletions
diff --git a/yt/cpp/mapreduce/client/batch_request_impl.cpp b/yt/cpp/mapreduce/client/batch_request_impl.cpp deleted file mode 100644 index 6afa5665f12..00000000000 --- a/yt/cpp/mapreduce/client/batch_request_impl.cpp +++ /dev/null @@ -1,198 +0,0 @@ -#include "batch_request_impl.h" - -#include "lock.h" - -#include <yt/cpp/mapreduce/common/helpers.h> -#include <yt/cpp/mapreduce/common/retry_lib.h> - -#include <yt/cpp/mapreduce/http/retry_request.h> - -#include <yt/cpp/mapreduce/interface/config.h> - -#include <yt/cpp/mapreduce/interface/logging/yt_log.h> - -#include <library/cpp/yson/node/node.h> -#include <library/cpp/yson/node/serialize.h> - -#include <yt/cpp/mapreduce/raw_client/raw_requests.h> -#include <yt/cpp/mapreduce/raw_client/raw_batch_request.h> -#include <yt/cpp/mapreduce/raw_client/rpc_parameters_serialization.h> - -#include <util/generic/guid.h> -#include <util/string/builder.h> - -#include <exception> - -namespace NYT { -namespace NDetail { - -using namespace NRawClient; - -using ::NThreading::TFuture; -using ::NThreading::TPromise; -using ::NThreading::NewPromise; - -//////////////////////////////////////////////////////////////////// - -TBatchRequest::TBatchRequest(const TTransactionId& defaultTransaction, ::TIntrusivePtr<TClient> client) - : DefaultTransaction_(defaultTransaction) - , Impl_(MakeIntrusive<TRawBatchRequest>(client->GetContext().Config)) - , Client_(client) -{ } - -TBatchRequest::TBatchRequest(TRawBatchRequest* impl, ::TIntrusivePtr<TClient> client) - : Impl_(impl) - , Client_(std::move(client)) -{ } - -TBatchRequest::~TBatchRequest() = default; - -IBatchRequestBase& TBatchRequest::WithTransaction(const TTransactionId& transactionId) -{ - if (!TmpWithTransaction_) { - TmpWithTransaction_.Reset(new TBatchRequest(Impl_.Get(), Client_)); - } - TmpWithTransaction_->DefaultTransaction_ = transactionId; - return *TmpWithTransaction_; -} - -TFuture<TNode> TBatchRequest::Get( - const TYPath& path, - const TGetOptions& options) -{ - return Impl_->Get(DefaultTransaction_, path, options); -} - -TFuture<void> TBatchRequest::Set(const TYPath& path, const TNode& node, const TSetOptions& options) -{ - return Impl_->Set(DefaultTransaction_, path, node, options); -} - -TFuture<TNode::TListType> TBatchRequest::List(const TYPath& path, const TListOptions& options) -{ - return Impl_->List(DefaultTransaction_, path, options); -} - -TFuture<bool> TBatchRequest::Exists(const TYPath& path, const TExistsOptions& options) -{ - return Impl_->Exists(DefaultTransaction_, path, options); -} - -TFuture<ILockPtr> TBatchRequest::Lock( - const TYPath& path, - ELockMode mode, - const TLockOptions& options) -{ - auto convert = [waitable=options.Waitable_, client=Client_] (TFuture<TNodeId> nodeIdFuture) -> ILockPtr { - return ::MakeIntrusive<TLock>(nodeIdFuture.GetValue(), client, waitable); - }; - return Impl_->Lock(DefaultTransaction_, path, mode, options).Apply(convert); -} - -::NThreading::TFuture<void> TBatchRequest::Unlock( - const TYPath& path, - const TUnlockOptions& options = TUnlockOptions()) -{ - return Impl_->Unlock(DefaultTransaction_, path, options); -} - -TFuture<TLockId> TBatchRequest::Create( - const TYPath& path, - ENodeType type, - const TCreateOptions& options) -{ - return Impl_->Create(DefaultTransaction_, path, type, options); -} - -TFuture<void> TBatchRequest::Remove( - const TYPath& path, - const TRemoveOptions& options) -{ - return Impl_->Remove(DefaultTransaction_, path, options); -} - -TFuture<TNodeId> TBatchRequest::Move( - const TYPath& sourcePath, - const TYPath& destinationPath, - const TMoveOptions& options) -{ - return Impl_->Move(DefaultTransaction_, sourcePath, destinationPath, options); -} - -TFuture<TNodeId> TBatchRequest::Copy( - const TYPath& sourcePath, - const TYPath& destinationPath, - const TCopyOptions& options) -{ - return Impl_->Copy(DefaultTransaction_, sourcePath, destinationPath, options); -} - -TFuture<TNodeId> TBatchRequest::Link( - const TYPath& targetPath, - const TYPath& linkPath, - const TLinkOptions& options) -{ - return Impl_->Link(DefaultTransaction_, targetPath, linkPath, options); -} - -TFuture<void> TBatchRequest::AbortOperation(const NYT::TOperationId& operationId) -{ - return Impl_->AbortOperation(operationId); -} - -TFuture<void> TBatchRequest::CompleteOperation(const NYT::TOperationId& operationId) -{ - return Impl_->CompleteOperation(operationId); -} - -TFuture<void> TBatchRequest::SuspendOperation( - const TOperationId& operationId, - const TSuspendOperationOptions& options) -{ - return Impl_->SuspendOperation(operationId, options); -} - -TFuture<void> TBatchRequest::ResumeOperation( - const TOperationId& operationId, - const TResumeOperationOptions& options) -{ - return Impl_->ResumeOperation(operationId, options); -} - -TFuture<void> TBatchRequest::UpdateOperationParameters( - const NYT::TOperationId& operationId, - const NYT::TUpdateOperationParametersOptions& options) -{ - return Impl_->UpdateOperationParameters(operationId, options); -} - -TFuture<TRichYPath> TBatchRequest::CanonizeYPath(const TRichYPath& path) -{ - return Impl_->CanonizeYPath(path); -} - -TFuture<TVector<TTableColumnarStatistics>> TBatchRequest::GetTableColumnarStatistics( - const TVector<TRichYPath>& paths, - const NYT::TGetTableColumnarStatisticsOptions& options) -{ - return Impl_->GetTableColumnarStatistics(DefaultTransaction_, paths, options); -} - -TFuture<TCheckPermissionResponse> TBatchRequest::CheckPermission( - const TString& user, - EPermission permission, - const TYPath& path, - const TCheckPermissionOptions& options) -{ - return Impl_->CheckPermission(user, permission, path, options); -} - -void TBatchRequest::ExecuteBatch(const TExecuteBatchOptions& options) -{ - NYT::NDetail::ExecuteBatch(Client_->GetRetryPolicy()->CreatePolicyForGenericRequest(), Client_->GetContext(), *Impl_, options); -} - -//////////////////////////////////////////////////////////////////////////////// - -} // namespace NDetail -} // namespace NYT |
