Home
last modified time | relevance | path

Searched refs:job_config (Results 1 – 10 of 10) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dmap_job_control.py40 self.job_config = map_job_config.JobConfig._to_map_job_config(
71 model.MapreduceControl.abort(self.job_config.job_id)
115 def submit(cls, job_config, in_xg_transaction=False): argument
129 cls.__validate_job_config(job_config)
130 mapper_spec = job_config._get_mapper_spec()
133 mapreduce_params = job_config._get_mr_params()
135 job_config.job_name,
136 job_config.job_id,
139 util._obj_to_path(job_config._hooks_cls))
150 state = cls.__create_and_save_state(job_config, mapreduce_spec)
[all …]
Dsample_input_reader.py69 def split_input(cls, job_config): argument
71 params = job_config.input_reader_params
75 shard_count = job_config.shard_count
88 def validate(cls, job_config): argument
90 super(SampleInputReader, cls).validate(job_config)
92 params = job_config.input_reader_params
Dmodel_datastore_input_reader.py40 def split_input(cls, job_config): argument
42 params = job_config.input_reader_params
43 shard_count = job_config.shard_count
47 return super(ModelDatastoreInputReader, cls).split_input(job_config)
86 def validate(cls, job_config): argument
88 super(ModelDatastoreInputReader, cls).validate(job_config)
89 params = job_config.input_reader_params
Dinput_reader.py73 def split_input(cls, job_config): argument
91 def validate(cls, job_config): argument
102 if job_config.input_reader_cls != cls:
105 (cls, job_config.input_reader_cls))
Ddatastore_input_reader.py19 def validate(cls, job_config): argument
21 super(DatastoreInputReader, cls).validate(job_config)
22 params = job_config.input_reader_params
Doutput_writer.py37 def validate(cls, job_config): argument
48 if job_config.output_writer_cls != cls:
51 (cls, job_config.output_writer_cls))
Dabstract_datastore_input_reader.py90 def split_input(cls, job_config): argument
92 shard_count = job_config.shard_count
93 params = job_config.input_reader_params
262 def validate(cls, job_config): argument
264 super(AbstractDatastoreInputReader, cls).validate(job_config)
265 params = job_config.input_reader_params
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmap_job_context.py12 def __init__(self, job_config): argument
21 self.job_config = job_config
Dhandlers.py472 job_config = map_job.JobConfig._to_map_job_config(
475 job_context = map_job_context.JobContext(job_config)
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
D_gcs.py151 def validate(cls, job_config): argument
161 reader_params = job_config.input_reader_params
215 def split_input(cls, job_config): argument
229 reader_params = job_config.input_reader_params
250 for shard in range(0, job_config.shard_count):
251 shard_filenames = all_filenames[shard::job_config.shard_count]