diff options
| author | vvvv <[email protected]> | 2025-10-09 12:25:18 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2025-10-09 12:57:17 +0300 |
| commit | cb77d014972b2cdb27d2e6d979fc3a2772b27ad4 (patch) | |
| tree | 7f3bcd8ce71c6bd0f3ccc11e31b9f665475b819e /yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp | |
| parent | d58a8990d353b051c27e1069141117fdfde64358 (diff) | |
YQL-20086 minikql
commit_hash:e96f7390db5fcbe7e9f64f898141a263ad522daa
Diffstat (limited to 'yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp')
| -rw-r--r-- | yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp b/yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp index 9636817cd73..92a4f957912 100644 --- a/yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp +++ b/yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp @@ -26,7 +26,7 @@ public: *res = MakeTrueArray(ctx->memory_pool(), arr.length); } else { *res = MakeBitmapArray(ctx->memory_pool(), arr.length, arr.offset, - arr.buffers[0]->data()); + arr.buffers[0]->data()); } return arrow::Status::OK(); @@ -40,9 +40,9 @@ std::shared_ptr<arrow::compute::ScalarKernel> MakeBlockExistsKernel(const TVecto Y_DEBUG_ABORT_UNLESS(returnArrowType == arrow::uint8()); auto exec = std::make_shared<TBlockExistsExec>(); auto kernel = std::make_shared<arrow::compute::ScalarKernel>(ConvertToInputTypes(argTypes), ConvertToOutputType(resultType), - [exec](arrow::compute::KernelContext* ctx, const arrow::compute::ExecBatch& batch, arrow::Datum* res) { - return exec->Exec(ctx, batch, res); - }); + [exec](arrow::compute::KernelContext* ctx, const arrow::compute::ExecBatch& batch, arrow::Datum* res) { + return exec->Exec(ctx, batch, res); + }); kernel->null_handling = arrow::compute::NullHandling::OUTPUT_NOT_NULL; return kernel; } @@ -52,8 +52,8 @@ std::shared_ptr<arrow::compute::ScalarKernel> MakeBlockExistsKernel(const TVecto IComputationNode* WrapBlockExists(TCallable& callable, const TComputationNodeFactoryContext& ctx) { MKQL_ENSURE(callable.GetInputsCount() == 1, "Expected 1 arg"); auto compute = LocateNode(ctx.NodeLocator, callable, 0); - TComputationNodePtrVector argsNodes = { compute }; - TVector<TType*> argsTypes = { callable.GetInput(0).GetStaticType() }; + TComputationNodePtrVector argsNodes = {compute}; + TVector<TType*> argsTypes = {callable.GetInput(0).GetStaticType()}; auto kernel = MakeBlockExistsKernel(argsTypes, callable.GetType()->GetReturnType()); return new TBlockFuncNode(ctx.Mutables, ToDatumValidateMode(ctx.ValidateMode), "Exists", std::move(argsNodes), argsTypes, callable.GetType()->GetReturnType(), *kernel, kernel); } |
