YQL-9517: RPC Arrow reader YT column converters

ydb-platform · Dec 20, 2023 · 026d2e1 · 026d2e1
1 parent 66b69b6
commit 026d2e1
Show file tree

Hide file tree

Showing 11 changed files with 771 additions and 122 deletions.
diff --git a/ydb/library/yql/providers/common/dq/yql_dq_integration_impl.cpp b/ydb/library/yql/providers/common/dq/yql_dq_integration_impl.cpp
@@ -22,20 +22,6 @@ TMaybe<ui64> TDqIntegrationBase::EstimateReadSize(ui64, ui32, const TVector<cons
     return Nothing();
 }
 
-bool TDqIntegrationBase::CanBlockReadTypes(const TStructExprType* node) {
-    for (const auto& e: node->GetItems()) {
-        // Check type
-        auto type = e->GetItemType();
-        while (ETypeAnnotationKind::Optional == type->GetKind()) {
-            type = type->Cast<TOptionalExprType>()->GetItemType();
-        }
-        if (ETypeAnnotationKind::Data != type->GetKind()) {
-            return false;
-        }
-    }
-    return true;
-}
-
 TExprNode::TPtr TDqIntegrationBase::WrapRead(const TDqSettings&, const TExprNode::TPtr& read, TExprContext&) {
     return read;
 }