Searched refs:epoch_limit (Results 1 – 1 of 1) sorted by relevance
318 def _get_filename_queue(self, epoch_limit): argument352 lambda: epoch_limiter.count_up_to(epoch_limit),369 epoch_limit=self._read_num_records_hint)385 filename_queue, epoch_limiter = self._get_filename_queue(epoch_limit=2)