MCPcopy Create free account
hub / github.com/baidu/bigflow / foreach

Function foreach

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

Transform foreach implementation :param pvalue: PType :param fn: UDF :param side_inputs: SideInputs :return:

(pvalue, fn, *side_inputs, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 15

process_with_side_inputsMethod · 0.95
ForeachProcessorClass · 0.85
get_dealt_side_inputs_tupleMethod · 0.80
default_objectorMethod · 0.80
pipelineMethod · 0.80
set_cpuMethod · 0.80
set_memoryMethod · 0.80
allow_partial_processingMethod · 0.80
distribute_by_defaultMethod · 0.80
sink_byMethod · 0.80
getMethod · 0.45
doneMethod · 0.45

Tested by

no test coverage detected