YT-18571: Drop yt/yt/core/misc/singleton.h

[nodiff:caesar]
commit_hash:152409763d3e87b9199a34fb0854b1084817f82a

1 files changed, 6 insertions, 4 deletions

diff --git a/yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp b/yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp
index abdcb46ead..c8c2b61607 100644
--- a/yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp
+++ b/yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp
@@ -44,6 +44,8 @@
 #include <util/generic/size_literals.h>
 #include <util/stream/output.h>
 
+#include <mutex>
+
 namespace NYql::NDqs {
 
 using namespace NKikimr::NMiniKQL;
@@ -284,7 +286,7 @@ public:
         , std::shared_ptr<std::vector<TType*>> columnTypes
         , std::shared_ptr<std::vector<std::shared_ptr<arrow::DataType>>> arrowTypes
         , arrow::MemoryPool& pool, const NUdf::IPgBuilder* pgBuilder
-        , bool isNative, NKikimr::NMiniKQL::IStatsRegistry* jobStats) 
+        , bool isNative, NKikimr::NMiniKQL::IStatsRegistry* jobStats)
         : Consumer_(consumer)
         , ColumnTypes_(columnTypes)
         , JobStats_(jobStats)
@@ -561,7 +563,7 @@ public:
         , Result_(width)
     {
     }
-    
+
     NUdf::EFetchStatus WideFetch(NUdf::TUnboxedValue* output, ui32 width) {
         if (GotFinish_) {
             return NUdf::EFetchStatus::Finish;
@@ -574,7 +576,7 @@ public:
                 Source_->Finish();
                 return NUdf::EFetchStatus::Finish;
             }
-            
+
             for (size_t i = 0; i < Width_; ++i) {
                 YQL_ENSURE(batch->Columns[i].type()->Equals(Types_->at(i)));
                 output[i] = Source_->HolderFactory.CreateArrowBlock(std::move(batch->Columns[i]));
@@ -663,7 +665,7 @@ IComputationNode* CreateDqYtReadBlockWrapper(const TComputationNodeFactoryContex
         const TString& token, const NYT::TNode& inputSpec, const NYT::TNode& samplingSpec,
         const TVector<ui32>& inputGroups,
         TType* itemType, const TVector<TString>& tableNames, TVector<std::pair<NYT::TRichYPath, NYT::TFormat>>&& tables,
-        NKikimr::NMiniKQL::IStatsRegistry* jobStats, size_t inflight, size_t timeout, const TVector<ui64>& tableOffsets) 
+        NKikimr::NMiniKQL::IStatsRegistry* jobStats, size_t inflight, size_t timeout, const TVector<ui64>& tableOffsets)
 {
     return new TDqYtReadBlockWrapper(ctx, clusterName, token, inputSpec, samplingSpec, inputGroups, itemType,
                                                 tableNames, std::move(tables), jobStats, inflight, timeout, tableOffsets);