(table string)
| 251 | } |
| 252 | |
| 253 | func (s *StateTracker) IsTableComplete(table string) bool { |
| 254 | s.CopyRWMutex.RLock() |
| 255 | defer s.CopyRWMutex.RUnlock() |
| 256 | |
| 257 | return s.completedTables[table] |
| 258 | } |
| 259 | |
| 260 | // This is reasonably accurate if the rows copied are distributed uniformly |
| 261 | // between paginationKey = 0 -> max(paginationKey). It would not be accurate if the distribution is |