我将Google Cloud Dataflow与Python SDK结合使用。

我想要 ：

• 从主PCollection中获取唯一日期列表
• 遍历该列表中的日期以创建过滤的PCollection（每个过滤器都有一个唯一的日期），并将每个过滤的PCollection写入BigQuery中按时间划分的表中的分区。

如何获得该清单？在执行以下合并转换之后，我创建了一个ListPCollectionView对象，但是无法迭代该对象：

class ToUniqueList(beam.CombineFn):

    def create_accumulator(self):
        return []

    def add_input(self, accumulator, element):
        if element not in accumulator:
            accumulator.append(element)
        return accumulator

    def merge_accumulators(self, accumulators):
        return list(set(accumulators))

    def extract_output(self, accumulator):
        return accumulator


def get_list_of_dates(pcoll):

    return (pcoll
            | 'get the list of dates' >> beam.CombineGlobally(ToUniqueList()))

我做错了吗？最好的方法是什么？

谢谢。