diff options
| author | aozeritsky <aozeritsky@ydb.tech> | 2023-06-09 12:34:42 +0300 |
|---|---|---|
| committer | aozeritsky <aozeritsky@ydb.tech> | 2023-06-09 12:34:42 +0300 |
| commit | e2aabcfad3b78847a46f0a30bd5bd21b3471e883 (patch) | |
| tree | 79922793c77f439e5fc88d980d0604dc814e3ab7 | |
| parent | d62eb3886595104092fd222cd178ad865ba56c6f (diff) | |
| download | ydb-e2aabcfad3b78847a46f0a30bd5bd21b3471e883.tar.gz | |
Add additional counters
| -rw-r--r-- | ydb/library/yql/providers/dq/actors/task_controller_impl.h | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/ydb/library/yql/providers/dq/actors/task_controller_impl.h b/ydb/library/yql/providers/dq/actors/task_controller_impl.h index d032d2fd7d..bf44ca68a2 100644 --- a/ydb/library/yql/providers/dq/actors/task_controller_impl.h +++ b/ydb/library/yql/providers/dq/actors/task_controller_impl.h @@ -356,18 +356,21 @@ private: ADD_COUNTER(CpuTimeUs) ADD_COUNTER(ComputeCpuTimeUs) ADD_COUNTER(SourceCpuTimeUs) - ADD_COUNTER(PendingInputTimeUs) - ADD_COUNTER(PendingOutputTimeUs) - ADD_COUNTER(FinishTimeUs) + ADD_COUNTER(FirstRowTimeMs) + ADD_COUNTER(FinishTimeMs) ADD_COUNTER(InputRows) ADD_COUNTER(InputBytes) ADD_COUNTER(OutputRows) ADD_COUNTER(OutputBytes) + ADD_COUNTER(StartTimeMs) // profile stats ADD_COUNTER(BuildCpuTimeUs) ADD_COUNTER(WaitTimeUs) ADD_COUNTER(WaitOutputTimeUs) + ADD_COUNTER(PendingInputTimeUs) + ADD_COUNTER(PendingOutputTimeUs) + ADD_COUNTER(FinishTimeUs) for (const auto& ingress : s.GetIngress()) { TaskStat.SetCounter(TaskStat.GetCounterName("TaskRunner", labels, "Ingress" + ingress.GetName() + "Bytes"), ingress.GetBytes()); @@ -425,7 +428,7 @@ private: if (stats.GetFirstMessageMs() && stats.GetLastMessageMs()) { TaskStat.SetCounter(TaskStat.GetCounterName("TaskRunner", labels, "ActiveTimeUs"), - ( TInstant::MilliSeconds(stats.GetLastMessageMs()) - + ( TInstant::MilliSeconds(stats.GetLastMessageMs()) - TInstant::MilliSeconds(stats.GetFirstMessageMs()) ).MicroSeconds() ); } @@ -459,7 +462,7 @@ private: if (stats.GetFirstMessageMs() && stats.GetLastMessageMs()) { TaskStat.SetCounter(TaskStat.GetCounterName("TaskRunner", labels, "ActiveTimeUs"), - ( TInstant::MilliSeconds(stats.GetLastMessageMs()) - + ( TInstant::MilliSeconds(stats.GetLastMessageMs()) - TInstant::MilliSeconds(stats.GetFirstMessageMs()) ).MicroSeconds() ); } |