Searched refs:output_names (Results 1 – 5 of 5) sorted by relevance
124 output_names = mapper_pipeline.MapperPipeline.output_names variable in ReducePipeline192 output_names = mapper_pipeline.MapperPipeline.output_names variable in MapreducePipeline253 output_names = mapper_pipeline.MapperPipeline.output_names variable in _ReturnPipeline
57 output_names = [ variable in MapperPipeline62 "counters"] + pipeline_base._OutputSlotsMixin.output_names
31 output_names = ["result_status"] variable in _OutputSlotsMixin
144 static const char * const output_names[] = { "None", variable169 if (connector->connector_type < ARRAY_SIZE(output_names)) in printConnector()170 printf("Connector: %s-%d\n", output_names[connector->connector_type], in printConnector()
294 def __init__(self, output_names, force_strict=False): argument307 self._strict = len(output_names) > 0 or force_strict309 for name in output_names:429 output_names = [] variable in Pipeline478 self.outputs = PipelineFuture(self.output_names)590 outputs = PipelineFuture(pipeline_func_class.output_names)661 future = PipelineFuture(self.output_names, force_strict=True)687 future = PipelineFuture(self.output_names, force_strict=True)1961 if slot.name not in stage.output_names:1965 missing_outputs = set(stage.output_names) - found_outputs[all …]