diff options
author | babenko <babenko@yandex-team.com> | 2024-12-07 10:59:20 +0300 |
---|---|---|
committer | babenko <babenko@yandex-team.com> | 2024-12-07 11:21:07 +0300 |
commit | 86e09d742d9d49f23c5ea1b691b68e3a53f1f40d (patch) | |
tree | bf9f4ac541e8c65102d4f3bcbc6d2713713d9428 /yt/yql | |
parent | aef7a507c07498e9f36d97195449f6f85ff8b77e (diff) | |
download | ydb-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.cpp | 10 |
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); |