Skip to content

Commit 3e3115b

Browse files
authored
Extended External (Source/Sink) Stat fields (#14529)
1 parent 67030a9 commit 3e3115b

File tree

1 file changed

+37
-8
lines changed

1 file changed

+37
-8
lines changed

ydb/library/yql/dq/actors/protos/dq_stats.proto

Lines changed: 37 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,46 @@ message TDqAsyncBufferStats {
3737
uint64 QueuedRows = 15;
3838
}
3939

40+
message TDqStatsAggr {
41+
uint64 Min = 1;
42+
uint64 Max = 2;
43+
uint64 Sum = 3;
44+
uint64 Cnt = 4;
45+
repeated TDqHistoryItem History = 5;
46+
}
47+
48+
message TDqExternalAggrStats {
49+
TDqStatsAggr ExternalRows = 1;
50+
TDqStatsAggr ExternalBytes = 2;
51+
TDqStatsAggr StorageRows = 3;
52+
TDqStatsAggr StorageBytes = 4;
53+
TDqStatsAggr CpuTimeUs = 5;
54+
TDqStatsAggr WaitInputTimeUs = 6;
55+
TDqStatsAggr WaitOutputTimeUs = 7;
56+
TDqStatsAggr FirstMessageMs = 8;
57+
TDqStatsAggr LastMessageMs = 9;
58+
uint32 PartitionCount = 10;
59+
}
60+
61+
message TDqExternalStats {
62+
uint64 ExternalRows = 1;
63+
uint64 ExternalBytes = 2;
64+
uint64 StorageRows = 3;
65+
uint64 StorageBytes = 4;
66+
uint64 CpuTimeUs = 5;
67+
uint64 WaitInputTimeUs = 6;
68+
uint64 WaitOutputTimeUs = 7;
69+
uint64 FirstMessageMs = 8;
70+
uint64 LastMessageMs = 9;
71+
string PartitionId = 10;
72+
}
73+
4074
message TDqAsyncInputBufferStats {
4175
uint64 InputIndex = 1;
4276
string IngressName = 9;
4377

78+
TDqExternalAggrStats External = 13;
79+
repeated TDqExternalStats ExternalPartitions = 14;
4480
TDqAsyncBufferStats Ingress = 10;
4581
TDqAsyncBufferStats Push = 11;
4682
TDqAsyncBufferStats Pop = 12;
@@ -282,14 +318,6 @@ message TDqHistoryItem {
282318
uint64 Value = 2;
283319
}
284320

285-
message TDqStatsAggr {
286-
uint64 Min = 1;
287-
uint64 Max = 2;
288-
uint64 Sum = 3;
289-
uint64 Cnt = 4;
290-
repeated TDqHistoryItem History = 5;
291-
}
292-
293321
message TExtraStats {
294322
map<string, TDqStatsAggr> Stats = 1;
295323
}
@@ -322,6 +350,7 @@ message TDqAsyncStatsAggr {
322350
}
323351

324352
message TDqAsyncBufferStatsAggr {
353+
TDqExternalAggrStats External = 5;
325354
TDqAsyncStatsAggr Ingress = 1; // for Ingress only
326355
TDqAsyncStatsAggr Push = 2;
327356
TDqAsyncStatsAggr Pop = 3;

0 commit comments

Comments
 (0)