java8集合源码-beam-bigquery-utils:用于在ApacheBeam中使用BigQuery的实用程序集合

时间:2024-06-24 10:49:21
【文件属性】:

文件名称:java8集合源码-beam-bigquery-utils:用于在ApacheBeam中使用BigQuery的实用程序集合

文件大小:26KB

文件格式:ZIP

更新时间:2024-06-24 10:49:21

系统开源

java8集合源码适用于 Apache Beam 的 BigQuery 实用程序 一个小型实用程序库,用于简化 Apache Beam 管道中 BigQuery 的读取、写入和交互。 要求: Java 1.8+ 阿帕奇梁2.x 导入到您的项目 版本发布到 . Maven 项目会简单地添加一个依赖项,如下所示: com.windfalldata beam-bigquery-utils ${version} 转换TableRow 如果您通常将 BigQuery 作为输入源读取,那么您可能遇到过将TableRow的PCollection转换为对用户更友好的数据对象的过程。 在幕后, TableRow对象实际上只是 JSON。 我们利用这个事实来利用强大的 Jackson JSON 解析框架来为我们处理转换。 一个例子: Pipeline p = Pipeline.create(options); String bq


【文件预览】:
beam-bigquery-utils-master
----pom.xml(6KB)
----src()
--------test()
--------main()
----.gitignore(217B)
----README.md(6KB)

网友评论