MCPcopy Create free account
hub / github.com/FDA/openfda / mapreduce

Function mapreduce

openfda/parallel/mapreduce.py:146–277  ·  view source on GitHub ↗
(
  inputs,
  mapper,
  reducer,
  output_prefix,
  output_format=LevelDBOutput(),
  num_shards=None,
  map_workers=None)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 3

runMethod · 0.90
runMethod · 0.90
runMethod · 0.85

Calls 6

LevelDBOutputClass · 0.85
MRExceptionClass · 0.85
getMethod · 0.80
recommended_shardsMethod · 0.45
putMethod · 0.45
finalizeMethod · 0.45

Tested by

no test coverage detected