Searched defs:mapreduce_spec (Results 1 – 6 of 6) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | handlers.py | 982 mapreduce_spec, argument
1221 def _finalize_outputs(cls, mapreduce_spec, mapreduce_state): argument
1234 def _finalize_job(cls, mapreduce_spec, mapreduce_state): argument
1282 def _clean_up_mr(cls, mapreduce_spec): argument
1286 def get_task_name(mapreduce_spec, serial_id): argument
1302 def controller_parameters(mapreduce_spec, serial_id): argument
1321 mapreduce_spec, argument
1766 def _create_and_save_state(cls, mapreduce_spec, _app): argument
1791 mapreduce_spec, argument
1832 def schedule(cls, mapreduce_spec): argument
|
| D | hooks.py | 31 def __init__(self, mapreduce_spec): argument
|
| D | context.py | 228 mapreduce_spec=None): argument
397 def __init__(self, mapreduce_spec, shard_state, task_retry_count=0): argument
|
| D | util.py | 355 def create_datastore_write_config(mapreduce_spec): argument
|
| D | model.py | 590 mapreduce_spec = json_util.JsonProperty(MapreduceSpec, indexed=False) variable in MapreduceState
741 mapreduce_spec, argument
|
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/ |
| D | map_job_control.py | 189 def __create_and_save_state(cls, job_config, mapreduce_spec): argument
211 def __add_kickoff_task(cls, job_config, mapreduce_spec): argument
|