Home
last modified time | relevance | path

Searched refs:BUCKET_NAME_PARAM (Results 1 – 4 of 4) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
D_gcs.py82 BUCKET_NAME_PARAM = "bucket_name" variable in GCSInputReader
164 if cls.BUCKET_NAME_PARAM not in reader_params:
167 cls.BUCKET_NAME_PARAM)
170 reader_params[cls.BUCKET_NAME_PARAM])
230 bucket = reader_params[cls.BUCKET_NAME_PARAM]
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Doutput_writers.py478 BUCKET_NAME_PARAM = "bucket_name" variable in _GoogleCloudStorageBase
490 return writer_spec[cls.BUCKET_NAME_PARAM]
580 if (mapper_spec.params.get(cls.BUCKET_NAME_PARAM) is not None and
581 params.get(cls.BUCKET_NAME_PARAM) is None):
582 params[cls.BUCKET_NAME_PARAM] = mapper_spec.params[cls.BUCKET_NAME_PARAM]
599 if cls.BUCKET_NAME_PARAM not in writer_spec:
602 cls.BUCKET_NAME_PARAM)
605 writer_spec[cls.BUCKET_NAME_PARAM])
Dshuffler.py416 BUCKET_NAME_PARAM = "bucket_name" variable in _HashingGCSOutputWriter
441 if cls.BUCKET_NAME_PARAM not in params:
444 cls.BUCKET_NAME_PARAM)
477 bucket_name = params.get(cls.BUCKET_NAME_PARAM)
Dinput_readers.py2279 BUCKET_NAME_PARAM = "bucket_name" variable in _GoogleCloudStorageInputReader
2356 if (mapper_spec.params.get(cls.BUCKET_NAME_PARAM) is not None and
2357 params.get(cls.BUCKET_NAME_PARAM) is None):
2358 params[cls.BUCKET_NAME_PARAM] = mapper_spec.params[cls.BUCKET_NAME_PARAM]
2375 if cls.BUCKET_NAME_PARAM not in reader_spec:
2378 cls.BUCKET_NAME_PARAM)
2381 reader_spec[cls.BUCKET_NAME_PARAM])
2423 bucket = reader_spec[cls.BUCKET_NAME_PARAM]