HomeSort by relevance Sort by last modified time
    Searched refs:map_job (Results 1 - 10 of 10) sorted by null

  /external/chromium-trace/catapult/perf_insights/perf_insights/endpoints/cloud_mapper/
worker.py 127 map_job = subprocess.Popen(args,
136 if map_job.poll():
139 if map_job.poll() is None:
142 os.killpg(os.getpgid(map_job.pid), signal.SIGTERM)
146 if map_job.stdout:
147 stdout = map_job.stdout.read()
148 if map_job.stderr:
149 stderr = map_job.stderr.read()
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
control.py 34 from mapreduce.api import map_job
53 Deprecated! Use map_job.start instead.
95 mr_params = map_job.JobConfig._get_default_mr_params()
handlers.py 57 from mapreduce.api import map_job
472 job_config = map_job.JobConfig._to_map_job_config(
626 if isinstance(handler, map_job.Mapper):
    [all...]
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
datastore_input_reader.py 2 """Datastore Input Reader implementation for the map_job API."""
7 from mapreduce.api.map_job import abstract_datastore_input_reader
sample_input_reader.py 10 from mapreduce.api import map_job
21 class SampleInputReader(map_job.InputReader):
map_job_config.py 8 from mapreduce.api.map_job import input_reader
9 from mapreduce.api.map_job import mapper as mapper_module
16 # Current API Version. The API version used to start a map_job will be
60 # This number is only a hint to the map_job framework. This will be
195 # handler_spec from older API may not have map_job.Mapper type.
map_job_control.py 9 from mapreduce.api.map_job import map_job_config
107 from the argument of map_job.output_writer.commit_output.
119 job_config: an instance of map_job.MapJobConfig.
195 job_config: map_job.JobConfig.
215 job_config: map_job.JobConfig.
model_datastore_input_reader.py 2 """Model Datastore Input Reader implementation for the map_job API."""
13 from mapreduce.api.map_job import abstract_datastore_input_reader
abstract_datastore_input_reader.py 2 """Abstract Datastore Input Reader implementation for the map_job API."""
12 from mapreduce.api.map_job import input_reader
  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
_gcs.py 19 from mapreduce.api import map_job
51 class GCSInputReader(map_job.InputReader):
155 job_config: map_job.JobConfig.
224 job_config: map_job.JobConfig

Completed in 64 milliseconds