对于给定的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 not stored for this graph (policy: none)
no outgoing calls
no test coverage detected