Searched refs:input_reader_class (Results 1 – 5 of 5) sorted by relevance
1452 input_reader_class = state.mapreduce_spec.mapper.input_reader_class()1454 if issubclass(input_reader_class, map_job.InputReader):1459 readers = input_reader_class.split_input(split_param)1461 readers = [input_reader_class.from_json_str(_json) for _json in1724 mapper_input_reader_class = mapper_spec.input_reader_class()
202 if mapper_spec.input_reader_class() != cls:1099 if mapper_spec.input_reader_class() != cls:1377 if mapper_spec.input_reader_class() != cls:1554 if mapper_spec.input_reader_class() != cls:1666 if mapper_spec.input_reader_class() != cls:1893 if mapper_spec.input_reader_class() != cls:1978 if mapper_spec.input_reader_class() != cls:2192 if mapper_spec.input_reader_class() != cls:
396 def input_reader_class(self): member in MapperSpec826 input_reader = mapper_spec.input_reader_class().from_json(830 initial_input_reader = mapper_spec.input_reader_class().from_json(
397 if mapper_spec.input_reader_class() != cls:
173 input_reader_cls = mapper_spec.input_reader_class()