Apache Beam 是一个分布式数据处理框架，其中有许多用于处理顺序元素（如列表、字典等）的 API 和方法。

以下是一些处理顺序元素的示例代码：

1. 使用 ParDo 处理列表元素

import apache_beam as beam

class MyDoFn(beam.DoFn):
    def process(self, element):
        yield sum(element)/len(element)

input_list = [1, 2, 3, 4, 5, 6]
with beam.Pipeline() as p:
    output = (
        p
        | "Create Input" >> beam.Create([input_list])
        | "ParDo" >> beam.ParDo(MyDoFn())
    )
    result = list(output)[0]
    print(result) # 3.5

2. 使用 Map 处理字典元素

import apache_beam as beam

input_dict = {"apple": 2, "banana": 3, "orange": 4}
with beam.Pipeline() as p:
    output = (
        p
        | "Create Input" >> beam.Create([input_dict])
        | "Map" >> beam.Map(lambda x: {k: v+1 for k, v in x.items()})
    )
    result = list(output)[0]
    print(result) # {'apple': 3, 'banana': 4, 'orange': 5}

3. 使用 FlatMap 处理嵌套列表

import apache_beam as beam

input_list = [[1, 2], [3, 4], [5, 6]]
with beam.Pipeline() as p:
    output = (
        p
        | "Create Input" >> beam.Create([input_list])
        | "FlatMap" >> beam.FlatMap(lambda x: x)
        | "Map" >> beam.Map(lambda x: x*2)
    )
    result = list(output)
    print(result) # [2, 4, 6, 8, 10, 12]

可以看到，Apache Beam 提供了灵活的 API 和方法来处理顺序元素，可以根据不同的需求选择合适的方法进行处理。