YQL-17542 split stat (#1553)

Author: zverevgeny

ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp

@@ -789,6 +789,11 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC
         return TaskRunnerStats.Get();
     }
 
+    const NYql::NDq::TDqMeteringStats* GetMeteringStats() override {
+        // TODO: support async CA
+        return nullptr;
+    }
+
     template<typename TSecond>
     TVector<ui32> GetIds(const THashMap<ui64, TSecond>& collection) {
         TVector<ui32> ids;

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

@@ -1758,9 +1758,8 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
         }
     }
 
-    virtual const NYql::NDq::TTaskRunnerStatsBase* GetTaskRunnerStats() {
-        return TaskRunner ? TaskRunner->GetStats() : nullptr;
-    }
+    virtual const NYql::NDq::TTaskRunnerStatsBase* GetTaskRunnerStats() = 0;
+    virtual const NYql::NDq::TDqMeteringStats* GetMeteringStats() = 0;
 
     virtual const IDqAsyncOutputBuffer* GetSink(ui64, const TAsyncOutputInfoBase& sinkInfo) const {
         return sinkInfo.Buffer.Get();
@@ -1820,8 +1819,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
 
             for (auto& [inputIndex, sourceInfo] : SourcesMap) {
                 if (auto* source = sourceInfo.AsyncInput) {
-                    // TODO: support async CA
-                    source->FillExtraStats(protoTask, last, TaskRunner ? TaskRunner->GetMeteringStats() : nullptr);
+                    source->FillExtraStats(protoTask, last, GetMeteringStats());
                 }
             }
             FillTaskRunnerStats(Task.GetId(), Task.GetStageId(), *taskStats, protoTask, RuntimeSettings.GetCollectStatsLevel());
@@ -1926,8 +1924,7 @@ class TDqComputeActorBase : public NActors::TActorBootstrapped<TDerived>
                 }
 
                 if (auto* transform = transformInfo.AsyncInput) {
-                    // TODO: support async CA
-                    transform->FillExtraStats(protoTask, last, TaskRunner ? TaskRunner->GetMeteringStats() : 0);
+                    transform->FillExtraStats(protoTask, last, GetMeteringStats());
                 }
             }
 

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

@@ -123,6 +123,14 @@ class TDqSyncComputeActorBase: public TDqComputeActorBase<TDerived, TComputeActo
             this->TaskRunner->GetRandomProvider()
         );
     }
+
+    const NYql::NDq::TTaskRunnerStatsBase* GetTaskRunnerStats() override {
+        return this->TaskRunner ? this->TaskRunner->GetStats() : nullptr;
+    }
+
+    const NYql::NDq::TDqMeteringStats* GetMeteringStats() override {
+        return this->TaskRunner ? this->TaskRunner->GetMeteringStats() : nullptr;
+    }
 };
 
 } //namespace NYql::NDq