Function cogroup

bigflow_python/python/bigflow/transform_impls/cogroup.py:37–80 · view source on GitHub ↗

(*pcollections, **kargs)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

nothing calls this directly

_make_shuffleFunction · 0.85

pipelineMethod · 0.80

default_objectorMethod · 0.80

appendMethod · 0.80

with_concurrencyMethod · 0.80

mapFunction · 0.70

sumFunction · 0.70

getMethod · 0.45

serdeMethod · 0.45

planMethod · 0.45

nodeMethod · 0.45

scopeMethod · 0.45

no test coverage detected