我有一个用python编写的sdf：

class Foo(DoFn):
    def process(element: Pipeline) -> Iterable[str]:
        ...

根据文档，SDF用于实现io。对于我的io，我不需要将输入元素传递给 DoFn . 将sdf添加到管道中的唯一选项似乎是 ParDo :

p | ParDo(Foo())

这样做是失败的，因为它需要一个窗口，而窗口不存在。即使在手动添加窗口时，它在以后进行其他假设时仍然失败。
那么，如何在没有任何输入元素的情况下编写sdf并将其直接添加到管道中呢？