Home
last modified time | relevance | path

Searched defs:job_config (Results 1 – 9 of 9) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dmap_job_control.py115 def submit(cls, job_config, in_xg_transaction=False): argument
182 def __validate_job_config(cls, job_config): argument
189 def __create_and_save_state(cls, job_config, mapreduce_spec): argument
211 def __add_kickoff_task(cls, job_config, mapreduce_spec): argument
Dmodel_datastore_input_reader.py40 def split_input(cls, job_config): argument
86 def validate(cls, job_config): argument
Dsample_input_reader.py69 def split_input(cls, job_config): argument
88 def validate(cls, job_config): argument
Dinput_reader.py73 def split_input(cls, job_config): argument
91 def validate(cls, job_config): argument
Dabstract_datastore_input_reader.py90 def split_input(cls, job_config): argument
262 def validate(cls, job_config): argument
Ddatastore_input_reader.py19 def validate(cls, job_config): argument
Doutput_writer.py37 def validate(cls, job_config): argument
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
D_gcs.py151 def validate(cls, job_config): argument
215 def split_input(cls, job_config): argument
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmap_job_context.py12 def __init__(self, job_config): argument