Function flat_map

对PCollection中的每个元素做一对N映射 对变换函数必须返回一个可遍历变量(即实现了__iter__()方法)，将迭代器中的所有元素 构造PCollection 假设输入类型为I，fn的期望签名为 fn(I) => [O...]，[]表示返回结果可遍历 Args: pvalue (PCollection or PObject): 输入P类型 fn (function): 变换函数 *side_inputs: 参与运算的SideInputs **options: 可配置选项

(pvalue, fn, *side_inputs, **options)