(table string, rowStats RowStats)
| 286 | } |
| 287 | |
| 288 | func (s *StateTracker) updateRowStatsForTable(table string, rowStats RowStats) { |
| 289 | s.rowStatsWrittenPerTable[table] = RowStats{ |
| 290 | NumBytes: rowStats.NumBytes + s.rowStatsWrittenPerTable[table].NumBytes, |
| 291 | NumRows: rowStats.NumRows + s.rowStatsWrittenPerTable[table].NumRows, |
| 292 | } |
| 293 | } |
| 294 | |
| 295 | func (s *StateTracker) updateSpeedLog(deltaPaginationKey float64) { |
| 296 | if s.iterationSpeedLog == nil { |
no outgoing calls
no test coverage detected