Searched refs:num_records_produced (Results 1 – 11 of 11) 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()
16 int64 num_records_produced = 3; field
18 name: "num_records_produced"
19 name: "num_records_produced"
211 def num_records_produced(self, name=None): member in ReaderBase
154 produced = reader.num_records_produced()208 produced = reader.num_records_produced()264 produced = reader.num_records_produced()