HomeSort by relevance Sort by last modified time
    Searched refs:BUCKET_NAME_PARAM (Results 1 - 4 of 4) sorted by null

  /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/lib/input_reader/
_gcs.py 55 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"
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/
output_writers.py 457 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"
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...]
shuffler.py 416 BUCKET_NAME_PARAM = "bucket_name"
441 if cls.BUCKET_NAME_PARAM not in params:
444 cls.BUCKET_NAME_PARAM)
477 bucket_name = params.get(cls.BUCKET_NAME_PARAM)
input_readers.py     [all...]

Completed in 45 milliseconds