YQ-2068 remove unused ProgramBuilder for transformer (#2162)

Author: zverevgeny

ydb/library/yql/dq/actors/compute/dq_compute_actor_async_io.h

@@ -234,6 +234,9 @@ struct IDqAsyncIoFactory : public TThrRefBase {
         IRandomProvider *const RandomProvider;
     };
 
+//TODO (YQ-2068) temporary flag for changing interface
+#define Y_YQL_DQ_NO_PROGRAM_BUILDER_FOR_TRANSFORM
+
     struct TInputTransformArguments {
         const NDqProto::TTaskInput& InputDesc;
         const ui64 InputIndex;
@@ -246,7 +249,6 @@ struct IDqAsyncIoFactory : public TThrRefBase {
         const NActors::TActorId& ComputeActorId;
         const NKikimr::NMiniKQL::TTypeEnvironment& TypeEnv;
         const NKikimr::NMiniKQL::THolderFactory& HolderFactory;
-        NKikimr::NMiniKQL::TProgramBuilder& ProgramBuilder;
         std::shared_ptr<NKikimr::NMiniKQL::TScopedAlloc> Alloc;
         NWilson::TTraceId TraceId;
     };
@@ -263,7 +265,6 @@ struct IDqAsyncIoFactory : public TThrRefBase {
         const THashMap<TString, TString>& TaskParams;
         const NKikimr::NMiniKQL::TTypeEnvironment& TypeEnv;
         const NKikimr::NMiniKQL::THolderFactory& HolderFactory;
-        NKikimr::NMiniKQL::TProgramBuilder& ProgramBuilder;
     };
 
     // Creates source.

ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h

@@ -801,7 +801,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
 
     struct TAsyncInputTransformHelper : TAsyncInputHelper {
         NUdf::TUnboxedValue InputBuffer;
-        TMaybe<NKikimr::NMiniKQL::TProgramBuilder> ProgramBuilder;
 
         using TAsyncInputHelper::TAsyncInputHelper;
     };
@@ -936,7 +935,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
 
     struct TAsyncOutputTransformInfo : public TAsyncOutputInfoBase {
         IDqOutputConsumer::TPtr OutputBuffer;
-        TMaybe<NKikimr::NMiniKQL::TProgramBuilder> ProgramBuilder;
     };
 
 protected:
@@ -1281,7 +1279,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
             this->RegisterWithSameMailbox(source.Actor);
         }
         for (auto& [inputIndex, transform] : InputTransformsMap) {
-            transform.ProgramBuilder.ConstructInPlace(typeEnv, *FunctionRegistry);
             Y_ABORT_UNLESS(AsyncIoFactory);
             const auto& inputDesc = Task.GetInputs(inputIndex);
             CA_LOG_D("Create transform for input " << inputIndex << " " << inputDesc.ShortDebugString());
@@ -1299,7 +1296,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
                         .ComputeActorId = this->SelfId(),
                         .TypeEnv = typeEnv,
                         .HolderFactory = holderFactory,
-                        .ProgramBuilder = *transform.ProgramBuilder,
                         .Alloc = Alloc,
                         .TraceId = ComputeActorSpan.GetTraceId()
                     });
@@ -1309,7 +1305,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
             this->RegisterWithSameMailbox(transform.Actor);
         }
         for (auto& [outputIndex, transform] : OutputTransformsMap) {
-            transform.ProgramBuilder.ConstructInPlace(typeEnv, *FunctionRegistry);
             Y_ABORT_UNLESS(AsyncIoFactory);
             const auto& outputDesc = Task.GetOutputs(outputIndex);
             CA_LOG_D("Create transform for output " << outputIndex << " " << outputDesc.ShortDebugString());
@@ -1326,7 +1321,6 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
                         .TaskParams = taskParams,
                         .TypeEnv = typeEnv,
                         .HolderFactory = holderFactory,
-                        .ProgramBuilder = *transform.ProgramBuilder
                     });
             } catch (const std::exception& ex) {
                 throw yexception() << "Failed to create output transform " << outputDesc.GetTransform().GetType() << ": " << ex.what();