Searched defs:input_reader (Results 1 – 2 of 2) sorted by relevance
535 input_reader, argument607 def _process_datum(self, data, input_reader, ctx, transient_shard_state): argument
744 input_reader, argument