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

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
H A D_gcs.py55 BUCKET_NAME_PARAM: name of the bucket to use. No "/" prefix or suffix.
57 in the BUCKET_NAME_PARAM bucket. If the name ends with a * it will be
82 BUCKET_NAME_PARAM = "bucket_name" variable in class: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/
H A Doutput_writers.py457 BUCKET_NAME_PARAM: name of the bucket to use (with no extra delimiters or
475 consistent GCS output writers. Defaults to BUCKET_NAME_PARAM if not set.
478 BUCKET_NAME_PARAM = "bucket_name" variable in class:_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)
[all...]
H A Dshuffler.py416 BUCKET_NAME_PARAM = "bucket_name" variable in class:_HashingGCSOutputWriter
441 if cls.BUCKET_NAME_PARAM not in params:
444 cls.BUCKET_NAME_PARAM)
477 bucket_name = params.get(cls.BUCKET_NAME_PARAM)
H A Dinput_readers.py2254 BUCKET_NAME_PARAM: name of the bucket to use (with no extra delimiters or
2257 in the BUCKET_NAME_PARAM bucket. If the name ends with a * it will be
2279 BUCKET_NAME_PARAM = "bucket_name" variable in class:_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])
[all...]

Completed in 64 milliseconds