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

Function pipe

bigflow_python/python/bigflow/transforms.py:1262–1337  ·  view source on GitHub ↗

对于给定的PCollection/PTable,返回通过command处理后的PCollection Args: pvalue (PCollection/PTable): 输入 command: 命令行 **options: 可配置选项 type: pipe类型,目前支持streaming和bistreaming,默认为streaming buffer_size: 缓存大小(单条数据),默认64MB input_fields_num: 输入command的一条数据有几个field,默认

(pvalue, command, **options)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

CreateOutputChannelMethod · 0.50
popen3Function · 0.50

Calls

no outgoing calls

Tested by

no test coverage detected