运行 Google 数据流中的单个操作

Question

如何将作业开始的时间和使用的选项（参数）写入 BigQuery？

换句话说，如何将 List<String> 转换为具有 1 个条目的 PCollection<List<String>>，以便它可以输出到 BigQuery 中的单行？

Answer 1

如果我没理解错的话。我想你正在寻找：

p.apply(Create.of(LINES)).setCoder(StringUtf8Coder.of())

上面会给你PCollection<String>

Run a single operation in Google Dataflow