Function foreach

对给定的PCollection/PObject中的每个元素应用一个函数，函数并不期望有任何的 返回，而是利用其副作用产生效果。 该函数一般用于产出数据到外部存储，同一条数据可能会被多次调用， 用户需要注意在下游去重，或想办法保证foreach操作具有幂等性质。 假设输入类型为I，fn的期望签名为 fn(I) => object，即返回值类型任意(并被忽略) Args: pvalue (PCollection or PObject): 输入P类型 fn (function): 变换函数 *side_in

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