Searched refs:mr_util (Results 1 – 1 of 1) sorted by relevance
69 import util as mr_util namespace275 value, cls=mr_util.JsonEncoder), cls=mr_util.JsonDecoder)471 self.target = mr_util._get_task_target()580 pipeline_func_class = mr_util.for_name(pipeline_record.class_path)1398 params_encoded = json.dumps(params, cls=mr_util.JsonEncoder)1468 cls=mr_util.JsonEncoder)1887 pipeline_generator = mr_util.is_generator_function(stage.run)2036 pipeline_func_class = mr_util.for_name(pipeline_record.class_path)2070 pipeline_generator = mr_util.is_generator_function(2809 pipeline_func_class = mr_util.for_name(real_class_path)