我有一个任务，通过它我可以写入数据库，哪些任务已成功处理。我正在尝试从我的 python 操作员那里获取信息TaskInstance.current_status()。但是，我似乎找不到成功获取 TaskInstance 的方法。如何获取任务实例并传递给TaskInstance()？我试过了task_id，但似乎不能是字符串
由于文档仅适用于JAVA,我无法理解其含义.
它声明 - "虽然ParDo总是产生一个主输出PCollection(作为应用的返回值),你也可以让你的ParDo产生任意数量的额外输出PCollections.如果你选择有多个输出,你的ParDo将返回所有的输出PCollections(包括主输出)捆绑在一起.例如,在Java中,输出PCollections捆绑在一个类型安全的PCollectionTuple中."
我理解捆绑在一起意味着什么,但如果我在我的DoFn中产生一个标签,它是否会产生一个包含所有其他输出的空包,并在代码中遇到它们时产生其他输出？或者它等待所有产量准备好输入并将它们全部输出到一起？
文档中没有太多清晰度.虽然我认为它不会等待,只是遇到收益,但我仍然需要了解发生了什么.