Searched defs:job_config (Results 1 – 9 of 9) sorted by relevance
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
D | map_job_control.py | 115 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
|
D | model_datastore_input_reader.py | 40 def split_input(cls, job_config): argument 86 def validate(cls, job_config): argument
|
D | sample_input_reader.py | 69 def split_input(cls, job_config): argument 88 def validate(cls, job_config): argument
|
D | input_reader.py | 73 def split_input(cls, job_config): argument 91 def validate(cls, job_config): argument
|
D | abstract_datastore_input_reader.py | 90 def split_input(cls, job_config): argument 262 def validate(cls, job_config): argument
|
D | datastore_input_reader.py | 19 def validate(cls, job_config): argument
|
D | output_writer.py | 37 def validate(cls, job_config): argument
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/ |
D | _gcs.py | 151 def validate(cls, job_config): argument 215 def split_input(cls, job_config): argument
|
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
D | map_job_context.py | 12 def __init__(self, job_config): argument
|