[yql] Rename dq exec transformer

YQL-12393

ref:00c8a493f0c29b3a9d232f3c8336a6ff4c81ccf0

4 files changed, 9 insertions, 9 deletions

diff --git a/ydb/core/yq/libs/actors/run_actor.cpp b/ydb/core/yq/libs/actors/run_actor.cpp
index d0bbf667d95..941621ab687 100644
--- a/ydb/core/yq/libs/actors/run_actor.cpp
+++ b/ydb/core/yq/libs/actors/run_actor.cpp
@@ -1092,7 +1092,7 @@ private:
             QueryStateUpdateRequest.set_scope(Params.Scope.ToString());
             QueryStateUpdateRequest.mutable_query_id()->set_value(Params.QueryId);
             QueryStateUpdateRequest.set_owner_id(Params.Owner);
-            dataProvidersInit.push_back(GetDqDataProviderInitializer(&CreateInMemoryExecTransformer, NYq::CreateEmptyGateway(SelfId()), Params.DqCompFactory, {}, nullptr));
+            dataProvidersInit.push_back(GetDqDataProviderInitializer(&CreateDqExecTransformer, NYq::CreateEmptyGateway(SelfId()), Params.DqCompFactory, {}, nullptr));
         }
 
         {
diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
index 8759f442219..e4c29bef408 100644
--- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
+++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.cpp
@@ -218,16 +218,16 @@ private:
     void AfterOptimize(TTransformationPipeline*) const final {}
 };
 
-class TInMemoryExecTransformer: public TExecTransformerBase, TCounters
+class TDqExecTransformer: public TExecTransformerBase, TCounters
 {
 public:
-    TInMemoryExecTransformer(const TDqStatePtr& state)
+    TDqExecTransformer(const TDqStatePtr& state)
         : State(state)
         , DqTypeAnnotationTransformer(
             CreateTypeAnnotationTransformer(NDq::CreateDqTypeAnnotationTransformer(*State->TypeCtx), *State->TypeCtx))
     {
-        AddHandler({TStringBuf("Result")}, RequireNone(), Hndl(&TInMemoryExecTransformer::HandleResult));
-        AddHandler({TStringBuf("Pull")}, RequireNone(), Hndl(&TInMemoryExecTransformer::HandlePull));
+        AddHandler({TStringBuf("Result")}, RequireNone(), Hndl(&TDqExecTransformer::HandleResult));
+        AddHandler({TStringBuf("Pull")}, RequireNone(), Hndl(&TDqExecTransformer::HandlePull));
         AddHandler({TDqCnResult::CallableName()}, RequireNone(), Pass());
         AddHandler({TDqQuery::CallableName()}, RequireFirst(), Pass());
     }
@@ -1262,8 +1262,8 @@ private:
 
 }
 
-IGraphTransformer* CreateInMemoryExecTransformer(const TDqStatePtr& state) {
-    return new TInMemoryExecTransformer(state);
+IGraphTransformer* CreateDqExecTransformer(const TDqStatePtr& state) {
+    return new TDqExecTransformer(state);
 }
 
 } // namespace NYql
diff --git a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.h b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.h
index e6fdd644a1e..c2f37662904 100644
--- a/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.h
+++ b/ydb/library/yql/providers/dq/provider/exec/yql_dq_exectransformer.h
@@ -8,5 +8,5 @@ namespace NYql {
     struct TDqState;
     using TDqStatePtr = TIntrusivePtr<TDqState>;
 
-    IGraphTransformer* CreateInMemoryExecTransformer(const TDqStatePtr& state);
+    IGraphTransformer* CreateDqExecTransformer(const TDqStatePtr& state);
 } // namespace NYql
diff --git a/ydb/library/yql/providers/pq/provider/yql_pq_ut.cpp b/ydb/library/yql/providers/pq/provider/yql_pq_ut.cpp
index 4127452d120..c29dbabf1df 100644
--- a/ydb/library/yql/providers/pq/provider/yql_pq_ut.cpp
+++ b/ydb/library/yql/providers/pq/provider/yql_pq_ut.cpp
@@ -113,7 +113,7 @@ bool RunPqProgram(
     auto dqGateway = CreateLocalDqGateway(driver, functionRegistry.Get(), dqCompFactory, dqTaskTransformFactory, {});
 
     auto storage = NYql::CreateFileStorage({});
-    dataProvidersInit.push_back(NYql::GetDqDataProviderInitializer(&CreateInMemoryExecTransformer, dqGateway, dqCompFactory, {}, storage));
+    dataProvidersInit.push_back(NYql::GetDqDataProviderInitializer(&CreateDqExecTransformer, dqGateway, dqCompFactory, {}, storage));
 
     TExprContext moduleCtx;
     IModuleResolver::TPtr moduleResolver;