Searched refs:pipeline_base (Results 1 – 4 of 4) sorted by relevance
40 from mapreduce import pipeline_base59 class MapPipeline(pipeline_base._OutputSlotsMixin,60 pipeline_base.PipelineBase):97 class ReducePipeline(pipeline_base._OutputSlotsMixin,98 pipeline_base.PipelineBase):161 class MapreducePipeline(pipeline_base._OutputSlotsMixin,162 pipeline_base.PipelineBase):246 class _ReturnPipeline(pipeline_base._OutputSlotsMixin,247 pipeline_base.PipelineBase):
28 from mapreduce import pipeline_base34 class MapperPipeline(pipeline_base._OutputSlotsMixin,35 pipeline_base.PipelineBase):62 "counters"] + pipeline_base._OutputSlotsMixin.output_names
47 from mapreduce import pipeline_base167 class _SortChunksPipeline(pipeline_base.PipelineBase):208 class _CollectOutputFiles(pipeline_base.PipelineBase):226 class _CleanupOutputFiles(pipeline_base.PipelineBase):546 class _ShardOutputs(pipeline_base.PipelineBase):580 class _MergePipeline(pipeline_base.PipelineBase):634 class _HashPipeline(pipeline_base.PipelineBase):673 class ShufflePipeline(pipeline_base.PipelineBase):711 class _GCSCleanupPipeline(pipeline_base.PipelineBase):
33 from mapreduce import pipeline_base35 pipeline_base = None variable284 if pipeline_base:286 PipelineBase = pipeline_base.PipelineBase