Method run_mr

openfda/tests/parallel_test.py:35–65 · view source on GitHub ↗

(self,
             prefix, input_data,
             input_format=parallel.LineInput(),
             mapper=parallel.IdentityMapper(),
             reducer=parallel.IdentityReducer(),
             output_format=parallel.LevelDBOutput(),
             num_shards=5)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 6

test_identityMethod · 0.95

test_json_outputMethod · 0.95

test_jsonline_outputMethod · 0.95

test_lines_inputMethod · 0.95

test_sumMethod · 0.95

test_exceptionMethod · 0.95

Calls 2

make_filesMethod · 0.95

openMethod · 0.80

Tested by

no test coverage detected