从像 pub/sub 这样的无限源读取数据后，我正在应用窗口化。我需要将属于一个窗口的所有记录写入一个单独的文件。我在 Java 中找到了这个，但在 python 中找不到任何东西。
google-cloud-platform google-cloud-dataflow apache-beam
apache-beam ×1
google-cloud-dataflow ×1
google-cloud-platform ×1