Home
last modified time | relevance | path

Searched refs:BATCH_SIZE_PARAM (Results 1 – 2 of 2) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/api/map_job/
Dabstract_datastore_input_reader.py38 BATCH_SIZE_PARAM = "batch_size" variable in AbstractDatastoreInputReader
84 batch_size=int(params.get(cls.BATCH_SIZE_PARAM, cls._BATCH_SIZE)),
272 if cls.BATCH_SIZE_PARAM in params:
274 batch_size = int(params[cls.BATCH_SIZE_PARAM])
/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dinput_readers.py267 BATCH_SIZE_PARAM = "batch_size" variable in AbstractDatastoreInputReader
326 batch_size=int(params.get(cls.BATCH_SIZE_PARAM, cls._BATCH_SIZE)),
527 if cls.BATCH_SIZE_PARAM in params:
529 batch_size = int(params[cls.BATCH_SIZE_PARAM])
823 BATCH_SIZE_PARAM = "batch_size" variable in _OldAbstractDatastoreInputReader
1081 batch_size = int(params.get(cls.BATCH_SIZE_PARAM, cls._BATCH_SIZE))
1104 if cls.BATCH_SIZE_PARAM in params:
1106 batch_size = int(params[cls.BATCH_SIZE_PARAM])
1157 batch_size = int(params.get(cls.BATCH_SIZE_PARAM, cls._BATCH_SIZE))
1240 self.BATCH_SIZE_PARAM: self._batch_size,
[all …]