java - 在 Beam 中实现 GCS Blob 获取
问题描述
我目前正在尝试实现 a DoFn ProcessElement，我在其中接收 aBlobId作为输入并将 Blob 内容作为输出传递。从我所见，我可以使用 Beams 文件系统并通过它读取数据。
现在我特别想知道在 DataFlow 的上下文中，如果这样的代码/类已经存在（TextIO.read似乎做了类似的事情）。
不会破坏 Java HEAP 的方法的奖励积分。
解决方案
推荐阅读
- python - 根据列值复制数据框的特定行
- c# - 将长数据分成最多16个二维码并在C#中读取时将它们组合起来的“连接功能”
- arduino - 带伺服电机的arduino加速度计
- bash - 通过 bash 脚本打开文件并将一个字符串替换为另一个字符串
- lua - 车辆生成菜单在lua中无限循环
- python - 将文本区域输入从 html 传递到烧瓶
- java - ElasticSearch 2.4.1 通过 Spark 返回空数据集
- javascript - 如何在 React Js 中创建这 3 个按钮？
- python-3.x - #如何分析流式音频数据？
- sqlite - 具有多个条件的 Sqlite SELECT