`WriteToBigQuery` 和 `BigQuerySink` 有什么区别

Question

关注 this answer 我想知道 Apache Beam Python SDK WriteToBigQuery 和 BigQuerySink 之间的主要区别（如果有的话）是什么。

使用其中一个的注意事项或限制是什么？

Answer 1

正在寻找at sources：

BigQuerySink triggers a Dataflow native sink for BigQuery that only supports batch pipelines. Instead of using this sink directly, please use WriteToBigQuery transform that works for both batch and streaming pipelines.

他们似乎都在下面做了 similar thing 否则。