accessors usage for ssa program processing (#14605)

Author: ivanmorozov333

ydb/core/formats/arrow/accessor/plain/accessor.h

@@ -39,6 +39,18 @@ class TTrivialArray: public IChunkedArray {
         , Array(data) {
     }
 
+    static std::shared_ptr<arrow::Array> BuildArrayFromScalar(const std::shared_ptr<arrow::Scalar>& scalar) {
+        AFL_VERIFY(scalar);
+        auto builder = NArrow::MakeBuilder(scalar->type, 1);
+        TStatusValidator::Validate(builder->AppendScalar(*scalar));
+        return NArrow::FinishBuilder(std::move(builder));
+    }
+
+    TTrivialArray(const std::shared_ptr<arrow::Scalar>& scalar)
+        : TBase(1, EType::Array, TValidator::CheckNotNull(scalar)->type)
+        , Array(BuildArrayFromScalar(scalar)) {
+    }
+
     template <class TArrowDataType = arrow::StringType>
     class TPlainBuilder {
     private:

ydb/core/formats/arrow/accessor/sparsed/ut/ya.make

@@ -3,6 +3,10 @@ UNITTEST_FOR(ydb/core/formats/arrow/accessor/sparsed)
 SIZE(SMALL)
 
 PEERDIR(
+    ydb/core/formats/arrow/accessor/sparsed
+    ydb/core/formats/arrow/accessor/plain
+    ydb/core/formats/arrow
+    yql/essentials/public/udf/service/stub
 )
 
 YQL_LAST_ABI_VERSION()

ydb/core/formats/arrow/accessor/sparsed/ya.make

@@ -4,6 +4,10 @@ PEERDIR(
     ydb/core/formats/arrow/accessor/abstract
     ydb/library/formats/arrow
     ydb/library/formats/arrow/protos
+    ydb/core/formats/arrow/save_load
+    ydb/core/formats/arrow/serializer
+    ydb/core/formats/arrow/splitter
+    ydb/library/formats/arrow/accessor/common
 )
 
 SRCS(

ydb/core/formats/arrow/arrow_filter.cpp

@@ -114,17 +114,20 @@ bool SwitchCompare(const arrow::Datum& column, const std::shared_ptr<arrow::Arra
 
 template <typename T>
 void CompositeCompare(std::shared_ptr<T> some, std::shared_ptr<arrow::RecordBatch> borderBatch, std::vector<NArrow::ECompareResult>& rowsCmp) {
+    AFL_VERIFY(some);
+    AFL_VERIFY(borderBatch);
     auto key = borderBatch->schema()->fields();
-    Y_ABORT_UNLESS(key.size());
+    AFL_VERIFY(key.size());
 
     for (size_t i = 0; i < key.size(); ++i) {
         auto& field = key[i];
         auto typeId = field->type()->id();
         auto column = some->GetColumnByName(field->name());
         std::shared_ptr<arrow::Array> border = borderBatch->GetColumnByName(field->name());
-        Y_ABORT_UNLESS(column);
-        Y_ABORT_UNLESS(border);
-        Y_ABORT_UNLESS(some->schema()->GetFieldByName(field->name())->type()->id() == typeId);
+        AFL_VERIFY(column)("schema1", some->schema()->ToString())("schema2", borderBatch->schema()->ToString())("f", field->name());
+        AFL_VERIFY(border)("schema1", some->schema()->ToString())("schema2", borderBatch->schema()->ToString())("f", field->name());
+        AFL_VERIFY(some->schema()->GetFieldByName(field->name())->type()->id() == typeId)("schema1", some->schema()->ToString())(
+            "schema2", borderBatch->schema()->ToString())("f", field->name());
 
         if (SwitchCompare(column, border, rowsCmp)) {
             break;   // early exit in case we have all rows compared: no borders, can omit key tail