java - 如何更新 Google Cloud Dataflow 中的现有记录？

Question

是否可以使用 Google Cloud Dataflow 在现有表中更新或插入新行？

比如说我有下表：

Book Table
BookId String(10)
Title String(50)
Content String(300)
Genre String(10)

我里面已经有以下记录：

__________________________________________________
BookID     |   Title    | Content      | Genre   |
           |            |              |         |
1          | Deadlock   | Some Content |         |
2          | Arefureta  | Contentss    |         |
--------------------------------------------------

在这种情况下，我希望我的数据流在不影响当前记录的情况下填充流派列。

我怎样才能做到这一点？这甚至可能吗？或者 Google Cloud 数据流是否存在某种限制？

在运行数据流之后，我想要这样的结果：

__________________________________________________
BookID     |   Title    | Content      | Genre   |
           |            |              |         |
1          | Deadlock   | Some Content | Action  |
2          | Arefureta  | Contentss    |Adventure|
--------------------------------------------------

标签： javagoogle-cloud-dataflowapache-beam