Searched refs:_process_datum (Results 1 – 1 of 1) sorted by relevance
592 if not self._process_datum(607 def _process_datum(self, data, input_reader, ctx, transient_shard_state): member in MapperWorkerCallbackHandler