Searched refs:num_records_produced (Results 1 – 12 of 12) sorted by relevance
86 int64 num_records_produced = 0; in ReadUpTo() local107 ReadUpToLocked(remaining, keys, values, &num_records_produced, &at_end); in ReadUpTo()109 records_produced_this_call += num_records_produced; in ReadUpTo()112 num_records_produced_ += num_records_produced; in ReadUpTo()114 if (!at_end && status.ok() && num_records_produced == 0) { in ReadUpTo()241 num_records_produced_ = state.num_records_produced(); in RestoreBaseState()
15 int64 num_records_produced = 3; field
167 def num_records_produced(self, name=None): member in ParallelReader177 num_records = [r.num_records_produced() for r in self._readers]
18 name: "num_records_produced"
19 name: "num_records_produced"
211 def num_records_produced(self, name=None): member in ReaderBase
153 produced = reader.num_records_produced()207 produced = reader.num_records_produced()263 produced = reader.num_records_produced()