YQ-855: rename public metrics: messages -> records, add public metric late_events

ref:64046911269891febd9385bd96fd3fbb8ed679a5

1 files changed, 5 insertions, 2 deletions

diff --git a/ydb/library/yql/providers/dq/actors/task_controller.cpp b/ydb/library/yql/providers/dq/actors/task_controller.cpp
index 2b210fd28d..538959dca4 100644
--- a/ydb/library/yql/providers/dq/actors/task_controller.cpp
+++ b/ydb/library/yql/providers/dq/actors/task_controller.cpp
@@ -231,8 +231,11 @@ private:
                         else if (labels.count(SinkLabel)) publicCounterName = "query.output_bytes";
                         isDeriv = true;
                     } else if (name == "RowsIn") {
-                        if (labels.count(SourceLabel)) publicCounterName = "query.source_input_messages";
-                        else if (labels.count(SinkLabel)) publicCounterName = "query.sink_output_messages"; // RowsIn == RowsOut for Sinks
+                        if (labels.count(SourceLabel)) publicCounterName = "query.source_input_records";
+                        else if (labels.count(SinkLabel)) publicCounterName = "query.sink_output_records"; // RowsIn == RowsOut for Sinks
+                        isDeriv = true;
+                    } else if (name == "MultiHop_ThrownEventsCount") {
+                        publicCounterName = "query.late_events";
                         isDeriv = true;
                     }