Home
last modified time | relevance | path

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

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dmapreduce_pipeline.py56 _ReducerReader = input_readers._ReducerReader variable
Dinput_readers.py2596 class _ReducerReader(_GoogleCloudStorageRecordInputReader): class
2603 super(_ReducerReader, self).__init__(filenames, index, buffer_size,
2619 binary_record = super(_ReducerReader, self).next()
2699 result = super(_ReducerReader, self).to_json()
2714 result = super(_ReducerReader, cls).from_json(json)
2715 result.current_key = _ReducerReader.decode_data(json["current_key"])
2716 result.current_values = _ReducerReader.decode_data(json["current_values"])