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

Function pipe

bigflow_python/python/bigflow/transform_impls/pipe.py:29–89  ·  view source on GitHub ↗

Transform pipe implementation :param pvalue: PType :return: PCollection

(pvalue, command, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers

nothing calls this directly

Calls 15

nested_levelMethod · 0.80
flattenMethod · 0.80
key_serdesMethod · 0.80
StrSerdeMethod · 0.80
TupleSerdeMethod · 0.80
set_cpuMethod · 0.80
set_memoryMethod · 0.80
allow_partial_processingMethod · 0.80
ignore_groupMethod · 0.80
process_byMethod · 0.80
PipeProcessorMethod · 0.80
pipelineMethod · 0.80

Tested by

no test coverage detected