Searched refs:pipeline_base (Results 1 - 4 of 4) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
H A Dmapper_pipeline.py28 from mapreduce import pipeline_base namespace
34 class MapperPipeline(pipeline_base._OutputSlotsMixin,
35 pipeline_base.PipelineBase):
62 "counters"] + pipeline_base._OutputSlotsMixin.output_names
H A Dmapreduce_pipeline.py40 from mapreduce import pipeline_base namespace
59 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):
H A Dbase_handler.py33 from mapreduce import pipeline_base namespace
35 pipeline_base = None variable
284 if pipeline_base:
286 PipelineBase = pipeline_base.PipelineBase
H A Dshuffler.py47 from mapreduce import pipeline_base namespace
167 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):

Completed in 96 milliseconds