dataflow计算框架beam的示例代码