Searched refs:output_writer_class (Results 1 – 5 of 5) sorted by relevance
122 output_writer_class = mapper_spec.output_writer_class()123 if (output_writer_class and125 outputs = output_writer_class.get_filenames(mapreduce_state)
1229 if (mapreduce_spec.mapper.output_writer_class() and1231 mapreduce_spec.mapper.output_writer_class().finalize_job(mapreduce_state)1484 output_writer_class = state.mapreduce_spec.mapper.output_writer_class()1485 if output_writer_class:1486 output_writer_class.init_job(state)1555 writer_class = spec.mapper.output_writer_class()1728 mapper_output_writer_class = mapper_spec.output_writer_class()
404 def output_writer_class(self): member in MapperSpec834 if mapper_spec.output_writer_class():835 output_writer = mapper_spec.output_writer_class().from_json(838 assert isinstance(output_writer, mapper_spec.output_writer_class()), (840 mapper_spec.output_writer_class(),
437 if mapper_spec.output_writer_class() != cls:
179 output_writer_cls = mapper_spec.output_writer_class()