aboutsummaryrefslogtreecommitdiffstats
path: root/yt/yql
diff options
context:
space:
mode:
authorbabenko <babenko@yandex-team.com>2024-12-07 10:59:20 +0300
committerbabenko <babenko@yandex-team.com>2024-12-07 11:21:07 +0300
commit86e09d742d9d49f23c5ea1b691b68e3a53f1f40d (patch)
treebf9f4ac541e8c65102d4f3bcbc6d2713713d9428 /yt/yql
parentaef7a507c07498e9f36d97195449f6f85ff8b77e (diff)
downloadydb-86e09d742d9d49f23c5ea1b691b68e3a53f1f40d.tar.gz
YT-18571: Drop yt/yt/core/misc/singleton.h
[nodiff:caesar] commit_hash:152409763d3e87b9199a34fb0854b1084817f82a
Diffstat (limited to 'yt/yql')
-rw-r--r--yt/yql/providers/yt/comp_nodes/dq/dq_yt_block_reader.cpp10
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);