Function filter

对于给定的PCollection和一个断言函数，返回只满足断言函数元素的PCollection 假设输入类型为I，fn的期望签名为 fn(I) => bool Args: pcollection (PCollection): 输入PCollection fn (function): 断言函数 **options: 可配置选项 Returns: PCollection: 过滤结果 >>> from bigflow import transforms >>> _p = _pipelin

(pcollection, fn, *side_inputs, **options)