YQL-17542 remove unused abstraction (#1184)

1 files changed, 11 insertions, 26 deletions

diff --git a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
index bb1bb560eb..69395978b4 100644
--- a/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
+++ b/ydb/library/yql/providers/dq/task_runner/tasks_runner_local.cpp
@@ -193,12 +193,13 @@ private:
 
 /*______________________________________________________________________________________________*/
 
-class TAbstractFactory: public IProxyFactory {
+class TLocalFactory: public IProxyFactory {
 public:
-    TAbstractFactory(const NKikimr::NMiniKQL::IFunctionRegistry* functionRegistry,
+    TLocalFactory(const NKikimr::NMiniKQL::IFunctionRegistry* functionRegistry,
         NKikimr::NMiniKQL::TComputationNodeFactory compFactory,
         TTaskTransformFactory taskTransformFactory,
-        std::shared_ptr<NKikimr::NMiniKQL::TComputationPatternLRUCache> patternCache)
+        std::shared_ptr<NKikimr::NMiniKQL::TComputationPatternLRUCache> patternCache,
+        bool terminateOnError)
         : DeterministicMode(!!GetEnv("YQL_DETERMINISTIC_MODE"))
         , RandomProvider(
             DeterministicMode
@@ -210,6 +211,7 @@ public:
                 : CreateDefaultTimeProvider())
         , FunctionRegistry(functionRegistry)
         , TaskTransformFactory(std::move(taskTransformFactory))
+        , TerminateOnError(terminateOnError)
     {
         ExecutionContext.FuncRegistry = FunctionRegistry;
         ExecutionContext.ComputationFactory = compFactory;
@@ -218,29 +220,6 @@ public:
         ExecutionContext.PatternCache = patternCache;
     }
 
-protected:
-    bool DeterministicMode;
-    TIntrusivePtr<IRandomProvider> RandomProvider;
-    TIntrusivePtr<ITimeProvider> TimeProvider;
-    const NKikimr::NMiniKQL::IFunctionRegistry* FunctionRegistry;
-    TTaskTransformFactory TaskTransformFactory;
-
-    NDq::TDqTaskRunnerContext ExecutionContext;
-};
-
-/*______________________________________________________________________________________________*/
-
-class TLocalFactory: public TAbstractFactory {
-public:
-    TLocalFactory(const NKikimr::NMiniKQL::IFunctionRegistry* functionRegistry,
-        NKikimr::NMiniKQL::TComputationNodeFactory compFactory,
-        TTaskTransformFactory taskTransformFactory,
-        std::shared_ptr<NKikimr::NMiniKQL::TComputationPatternLRUCache> patternCache,
-        bool terminateOnError)
-        : TAbstractFactory(functionRegistry, compFactory, taskTransformFactory, patternCache)
-        , TerminateOnError(terminateOnError)
-    { }
-
     ITaskRunner::TPtr GetOld(const TDqTaskSettings& task, const TString& traceId) override {
         return new TLocalTaskRunner(task, Get(task, NDqProto::DQ_STATS_MODE_BASIC, traceId));
     }
@@ -287,6 +266,12 @@ public:
     }
 
 private:
+    bool DeterministicMode;
+    TIntrusivePtr<IRandomProvider> RandomProvider;
+    TIntrusivePtr<ITimeProvider> TimeProvider;
+    const NKikimr::NMiniKQL::IFunctionRegistry* FunctionRegistry;
+    TTaskTransformFactory TaskTransformFactory;
+    NDq::TDqTaskRunnerContext ExecutionContext;
     const bool TerminateOnError;
 };