generic provider: tune for KQP

Author: uzhastik

ydb/library/yql/providers/generic/provider/yql_generic_datasource.cpp

@@ -73,6 +73,25 @@ namespace NYql {
                 return node;
             }
 
+            bool CanPullResult(const TExprNode& node, TSyncMap& syncList, bool& canRef) override {
+                Y_UNUSED(syncList);
+                canRef = false;
+                if (node.IsCallable(TCoRight::CallableName())) {
+                    const auto input = node.Child(0);
+                    if (input->IsCallable(TGenReadTable::CallableName())) {
+                        return true;
+                    }
+                }
+                return false;
+            }
+
+            bool CanExecute(const TExprNode& node) override {
+                if (node.IsCallable(TGenReadTable::CallableName())) {
+                    return true;
+                }
+                return false;
+            }
+
             const THashMap<TString, TString>* GetClusterTokens() override {
                 return &State_->Configuration->Tokens;
             }

ydb/library/yql/providers/generic/provider/yql_generic_logical_opt.cpp

@@ -23,19 +23,12 @@ namespace NYql {
                 , State_(state)
             {
 #define HNDL(name) "LogicalOptimizer-" #name, Hndl(&TGenericLogicalOptProposalTransformer::name)
-                AddHandler(0, &TCoLeft::Match, HNDL(TrimReadWorld));
                 AddHandler(0, &TCoExtractMembers::Match, HNDL(ExtractMembers));
                 AddHandler(0, &TCoExtractMembers::Match, HNDL(ExtractMembersOverDqWrap));
                 AddHandler(0, &TCoExtractMembers::Match, HNDL(ExtractMembersOverDqSourceWrap));
 #undef HNDL
             }
 
-            TMaybeNode<TExprBase> TrimReadWorld(TExprBase node, TExprContext& ctx) const {
-                if (const auto maybeRead = node.Cast<TCoLeft>().Input().Maybe<TGenReadTable>())
-                    return TExprBase(ctx.NewWorld(node.Pos()));
-                return node;
-            }
-
             TMaybeNode<TExprBase> ExtractMembers(TExprBase node, TExprContext& ctx) const {
                 const auto extract = node.Cast<TCoExtractMembers>();
                 const auto input = extract.Input();

ydb/library/yql/providers/generic/provider/yql_generic_physical_opt.cpp

@@ -23,10 +23,17 @@ namespace NYql {
                 , State_(state)
             {
 #define HNDL(name) "PhysicalOptimizer-" #name, Hndl(&TGenericPhysicalOptProposalTransformer::name)
+                AddHandler(0, &TCoLeft::Match, HNDL(TrimReadWorld));
                 AddHandler(0, &TCoNarrowMap::Match, HNDL(ReadZeroColumns));
 #undef HNDL
             }
 
+            TMaybeNode<TExprBase> TrimReadWorld(TExprBase node, TExprContext& ctx) const {
+                if (const auto maybeRead = node.Cast<TCoLeft>().Input().Maybe<TGenReadTable>())
+                    return TExprBase(ctx.NewWorld(node.Pos()));
+                return node;
+            }
+
             TMaybeNode<TExprBase> ReadZeroColumns(TExprBase node, TExprContext& ctx) const {
                 const auto& narrow = node.Maybe<TCoNarrowMap>();
                 if (const auto& wide = narrow.Cast().Input().Maybe<TDqReadWideWrap>()) {