对包含的元素进行一对多变换,等同于 ``transforms.map(self, fn, *side_inputs, **options)`` Args: fn (function): 变换函数 *side_inputs: 参与运算的SideInputs **options: 可配置选项 Returns: PCollection: 变换结果 >>> _pipeline.parallelize(1).flat_map(lambda x:
(self, fn, *side_inputs, **option)
source not stored for this graph (policy: none)
no outgoing calls