summaryrefslogtreecommitdiffstats
path: root/yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-10-09 12:25:18 +0300
committervvvv <[email protected]>2025-10-09 12:57:17 +0300
commitcb77d014972b2cdb27d2e6d979fc3a2772b27ad4 (patch)
tree7f3bcd8ce71c6bd0f3ccc11e31b9f665475b819e /yql/essentials/minikql/comp_nodes/mkql_block_exists.cpp
parentd58a8990d353b051c27e1069141117fdfde64358 (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.cpp12
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);
}