@@ -144,14 +144,15 @@ class TDqInputImpl : public IInputInterface {
144
144
145
145
StoredBytes += space;
146
146
StoredRows += batch.RowCount ();
147
-
148
- if (static_cast <TDerived*>(this )->PushStats .CollectBasic ()) {
149
- static_cast <TDerived*>(this )->PushStats .Bytes += space;
150
- static_cast <TDerived*>(this )->PushStats .Rows += GetRowsCount (batch);
151
- static_cast <TDerived*>(this )->PushStats .Chunks ++;
152
- static_cast <TDerived*>(this )->PushStats .Resume ();
153
- if (static_cast <TDerived*>(this )->PushStats .CollectFull ()) {
154
- static_cast <TDerived*>(this )->PushStats .MaxMemoryUsage = std::max (static_cast <TDerived*>(this )->PushStats .MaxMemoryUsage , StoredBytes);
147
+ auto & pushStats = static_cast <TDerived*>(this )->PushStats ;
148
+
149
+ if (pushStats.CollectBasic ()) {
150
+ pushStats.Bytes += space;
151
+ pushStats.Rows += GetRowsCount (batch);
152
+ pushStats.Chunks ++;
153
+ pushStats.Resume ();
154
+ if (pushStats.CollectFull ()) {
155
+ pushStats.MaxMemoryUsage = std::max (pushStats.MaxMemoryUsage , StoredBytes);
155
156
}
156
157
}
157
158
@@ -172,7 +173,9 @@ class TDqInputImpl : public IInputInterface {
172
173
173
174
batch.clear ();
174
175
175
- static_cast <TDerived*>(this )->PopStats .Resume (); // save timing before processing
176
+ auto & popStats = static_cast <TDerived*>(this )->PopStats ;
177
+
178
+ popStats.Resume (); // save timing before processing
176
179
ui64 popBytes = 0 ;
177
180
178
181
if (IsPaused ()) {
@@ -228,10 +231,10 @@ class TDqInputImpl : public IInputInterface {
228
231
Batches.clear ();
229
232
}
230
233
231
- if (static_cast <TDerived*>( this )-> PopStats .CollectBasic ()) {
232
- static_cast <TDerived*>( this )-> PopStats .Bytes += popBytes;
233
- static_cast <TDerived*>( this )-> PopStats .Rows += GetRowsCount (batch);
234
- static_cast <TDerived*>( this )-> PopStats .Chunks ++;
234
+ if (popStats .CollectBasic ()) {
235
+ popStats .Bytes += popBytes;
236
+ popStats .Rows += GetRowsCount (batch);
237
+ popStats .Chunks ++;
235
238
}
236
239
237
240
Y_ABORT_UNLESS (!batch.empty ());
0 commit comments